diff --git a/CHANGELOG.md b/CHANGELOG.md
index 83d8f76..12b268a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,3 +1,6 @@
+## 6.1.2
+  - bump kafka dependency to 0.10.1.1
+
 ## 6.1.1
   - Docs: Clarify compatibility matrix and remove it from the changelog to avoid duplication.
 
diff --git a/kafka_test_setup.sh b/kafka_test_setup.sh
index 771fb17..40cdb15 100755
--- a/kafka_test_setup.sh
+++ b/kafka_test_setup.sh
@@ -5,7 +5,7 @@ set -ex
 if [ -n "${KAFKA_VERSION+1}" ]; then
   echo "KAFKA_VERSION is $KAFKA_VERSION"
 else
-   KAFKA_VERSION=0.10.1.0
+   KAFKA_VERSION=0.10.1.1
 fi
 
 echo "Downloading Kafka version $KAFKA_VERSION"
diff --git a/logstash-output-kafka.gemspec b/logstash-output-kafka.gemspec
index 33f06a4..32b7194 100644
--- a/logstash-output-kafka.gemspec
+++ b/logstash-output-kafka.gemspec
@@ -1,7 +1,7 @@
 Gem::Specification.new do |s|
 
   s.name            = 'logstash-output-kafka'
-  s.version         = '6.1.1'
+  s.version         = '6.1.2'
   s.licenses        = ['Apache License (2.0)']
   s.summary         = 'Output events to a Kafka topic. This uses the Kafka Producer API to write messages to a topic on the broker'
   s.description     = "This gem is a Logstash plugin required to be installed on top of the Logstash core pipeline using $LS_HOME/bin/logstash-plugin install gemname. This gem is not a stand-alone program"
@@ -19,7 +19,7 @@ Gem::Specification.new do |s|
   # Special flag to let us know this is actually a logstash plugin
   s.metadata = { 'logstash_plugin' => 'true', 'group' => 'output'}
 
-  s.requirements << "jar 'org.apache.kafka:kafka-clients', '0.10.1.0'"
+  s.requirements << "jar 'org.apache.kafka:kafka-clients', '0.10.1.1'"
   s.requirements << "jar 'org.slf4j:slf4j-log4j12', '1.7.21'"
 
   s.add_development_dependency 'jar-dependencies', '~> 0.3.2'