改名

2020-10-26 16:54:20 +08:00
parent 38d450ceed
commit f4c3b71452
1 changed files with 1 additions and 1 deletions
@@ -155,7 +155,7 @@ class Kafka extends \Snowflake\Process\Process
 		$conf->setRebalanceCb($rdCb);
 		$conf->set('group.id', uniqid('kafka'));
 		$conf->set('metadata.broker.list', $kafka['brokers']);
-		$conf->set('socket.timeout.ms', $kafka['timeout'] ?? 1000);
+		$conf->set('socket.timeout.ms', 3600 * 1000);

 		//多进程和信号
 		if (function_exists('pcntl_sigprocmask')) {