改名

2020-10-26 18:09:52 +08:00
parent 262c01be53
commit 72cb3beea1
1 changed files with 0 additions and 1 deletions
@@ -136,7 +136,6 @@ 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');