From b0826afedb2ae011a50555e1d899127024a39885 Mon Sep 17 00:00:00 2001 From: stephb9959 Date: Tue, 17 May 2022 12:34:53 -0700 Subject: [PATCH] Framework update. --- src/framework/MicroService.h | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/src/framework/MicroService.h b/src/framework/MicroService.h index 2c3ceb8..ba2480f 100644 --- a/src/framework/MicroService.h +++ b/src/framework/MicroService.h @@ -4124,9 +4124,7 @@ namespace OpenWifi { inline void KafkaProducer::run() { cppkafka::Configuration Config({ { "client.id", MicroService::instance().ConfigGetString("openwifi.kafka.client.id") }, - { "metadata.broker.list", MicroService::instance().ConfigGetString("openwifi.kafka.brokerlist") }, - { "reconnect.backoff.max.ms", 5000 }, - { "reconnect.backoff.ms", 100 } + { "metadata.broker.list", MicroService::instance().ConfigGetString("openwifi.kafka.brokerlist") } }); AddKafkaSecurity(Config); @@ -4166,9 +4164,7 @@ namespace OpenWifi { { "group.id", MicroService::instance().ConfigGetString("openwifi.kafka.group.id") }, { "enable.auto.commit", MicroService::instance().ConfigGetBool("openwifi.kafka.auto.commit",false) }, { "auto.offset.reset", "latest" } , - { "enable.partition.eof", false }, - { "reconnect.backoff.max.ms", 5000 }, - { "reconnect.backoff.ms", 100 } + { "enable.partition.eof", false } }); AddKafkaSecurity(Config);