改名
This commit is contained in:
+1
-1
@@ -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');
|
||||||
|
|
||||||
$conf->set('auto.create.topics.enable', true);
|
$conf->set('auto.create.topics.enable', 'true');
|
||||||
} catch (Throwable $exception) {
|
} catch (Throwable $exception) {
|
||||||
var_dump($exception->getMessage());
|
var_dump($exception->getMessage());
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user