改名

2020-10-26 18:09:27 +08:00
parent caaf5bba13
commit 262c01be53
1 changed files with 1 additions and 1 deletions
@@ -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');