This commit is contained in:
2020-12-02 17:33:31 +08:00
parent 9a5185a856
commit 4e0f1d5e69
+2 -2
View File
@@ -155,8 +155,8 @@ class Kafka extends \Snowflake\Process\Process
if (function_exists('pcntl_sigprocmask')) {
pcntl_sigprocmask(SIG_BLOCK, array(SIGIO));
$conf->set('internal.termination.signal', (string)SIGIO);
} else {
$conf->set('queue.buffering.max.ms', '1');
// } else {
// $conf->set('queue.buffering.max.ms', '1');
}
$topicConf = new TopicConf();