diff options
Diffstat (limited to 'src/objectscanner_kafka.cpp')
| -rw-r--r-- | src/objectscanner_kafka.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/objectscanner_kafka.cpp b/src/objectscanner_kafka.cpp index 6b52447..da53d67 100644 --- a/src/objectscanner_kafka.cpp +++ b/src/objectscanner_kafka.cpp @@ -107,7 +107,7 @@ int32_t rdkafka_consumer_init(void) /*Topic configuration*/ topic_conf = rd_kafka_topic_conf_new(); rd_kafka_topic_conf_set(topic_conf, "consume.callback.max.messages", confbuf, errString, 512); - rd_kafka_topic_conf_set(topic_conf, "auto.commit.enable", "true", errString, 512); + rd_kafka_topic_conf_set(topic_conf, "enable.auto.commit", "true", errString, 512); rd_kafka_topic_conf_set(topic_conf, "auto.offset.reset", "earliest", errString, 512); //RD_KAFKA_OFFSET_STORED��ʼû��offesetʱ if(rd_kafka_topic_conf_set(topic_conf, "offset.store.method", "broker", errString, 512) != RD_KAFKA_CONF_OK) { |