改名

2020-10-26 16:53:39 +08:00
parent 665dff9192
commit 38d450ceed
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'] ?? 50);
+		$conf->set('socket.timeout.ms', $kafka['timeout'] ?? 1000);

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