diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 78af6558..a7eafb65 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -166,7 +166,7 @@ class Kafka extends \Snowflake\Process\Process $topicConf->set('offset.store.path', 'kafka_offset.log'); $topicConf->set('offset.store.method', 'broker'); - $conf->set('auto.create.topics.enable', true); + $conf->set('auto.create.topics.enable', 'true'); } catch (Throwable $exception) { var_dump($exception->getMessage()); }