diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index c7064b7a..756a4a21 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -105,7 +105,6 @@ class Kafka extends \Snowflake\Process\Process
 
 	/**
 	 * @param $topic
-	 * @param $part
 	 * @param $message
 	 */
 	protected function handlerExecute($topic, $message)
@@ -137,6 +136,7 @@ class Kafka extends \Snowflake\Process\Process
 		$kafka = SConfig::get('kafka');
 		$conf->setRebalanceCb([$this, 'rebalanced_cb']);
 		$conf->set('group.id', uniqid('kafka'));
+		$conf->set('version', '2.6.0');
 
 		$conf->set('metadata.broker.list', '127.0.0.1:9092');
 		$conf->set('auto.offset.reset', 'earliest');