scottk/wlan-cloud-ucentralsec
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git synced 2025-11-02 03:37:51 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Framework update.

Browse Source
This commit is contained in:
stephb9959
2022-05-17 12:31:29 -07:00
parent 9bc6372a42
commit 2d074f455e
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/framework/MicroService.h
View File

@@ -4124,9 +4124,7 @@ namespace OpenWifi {
inline void KafkaProducer::run() { inline void KafkaProducer::run() {
cppkafka::Configuration Config({ cppkafka::Configuration Config({
{ "client.id", MicroService::instance().ConfigGetString("openwifi.kafka.client.id") }, { "client.id", MicroService::instance().ConfigGetString("openwifi.kafka.client.id") },
{ "metadata.broker.list", MicroService::instance().ConfigGetString("openwifi.kafka.brokerlist") }, { "metadata.broker.list", MicroService::instance().ConfigGetString("openwifi.kafka.brokerlist") }
{ "reconnect.backoff.max.ms", 5000 },
{ "reconnect.backoff.ms", 100 }
}); });
AddKafkaSecurity(Config); AddKafkaSecurity(Config);
@@ -4166,9 +4164,7 @@ namespace OpenWifi {
{ "group.id", MicroService::instance().ConfigGetString("openwifi.kafka.group.id") }, { "group.id", MicroService::instance().ConfigGetString("openwifi.kafka.group.id") },
{ "enable.auto.commit", MicroService::instance().ConfigGetBool("openwifi.kafka.auto.commit",false) }, { "enable.auto.commit", MicroService::instance().ConfigGetBool("openwifi.kafka.auto.commit",false) },
{ "auto.offset.reset", "latest" } , { "auto.offset.reset", "latest" } ,
{ "enable.partition.eof", false }, { "enable.partition.eof", false }
{ "reconnect.backoff.max.ms", 5000 },
{ "reconnect.backoff.ms", 100 }
}); });
AddKafkaSecurity(Config); AddKafkaSecurity(Config);