diff options
| author | [email protected] <[email protected]> | 2019-11-21 17:05:35 +0800 |
|---|---|---|
| committer | [email protected] <[email protected]> | 2019-11-21 17:05:35 +0800 |
| commit | f1642106ced3d5222ad7c2f04a417087fee02efc (patch) | |
| tree | 56f2589977b1c6851b639015cdd337cbdb48b154 /src/objectscanner_kafka.cpp | |
| parent | e6f1cba3653dfdf66aaec28a9f51b80812d5149e (diff) | |
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) { |