From f1642106ced3d5222ad7c2f04a417087fee02efc Mon Sep 17 00:00:00 2001 From: "linuxrc@163.com" Date: Thu, 21 Nov 2019 17:05:35 +0800 Subject: 适配最新的tango cache client. MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/objectscanner_kafka.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'src/objectscanner_kafka.cpp') 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) { -- cgit v1.2.3