This commit is contained in:
2021-01-14 10:37:38 +08:00
parent bcb6f6ee9c
commit 9d181c05f0
+1 -1
View File
@@ -166,7 +166,7 @@ class Kafka extends \Snowflake\Process\Process
$topicConf->set('offset.store.path', 'kafka_offset.log'); $topicConf->set('offset.store.path', 'kafka_offset.log');
$topicConf->set('offset.store.method', 'broker'); $topicConf->set('offset.store.method', 'broker');
var_dump($topicConf->dump()); var_dump($topicConf);
$topicConf->set('auto.create.topics.enable', 'true'); $topicConf->set('auto.create.topics.enable', 'true');
} catch (Throwable $exception) { } catch (Throwable $exception) {