Compare commits

...

5 Commits

Author SHA1 Message Date
TIP Automation User
7be170a0bd Chg: update image tag in helm values to v3.2.0-RC1 2024-09-11 17:50:51 +00:00
i-chvets
1d703e1737 Merge pull request #111 from Telecominfraproject/WIFI-13857-fix-svc-kafka-startup
WIFI-13857: fix: modified code to use flush() when internal queue is not loaded
2024-06-19 16:59:56 -04:00
Ivan Chvets
22ddb40d4c fix: modified code to use flush() when internal queue is not loaded
https://telecominfraproject.atlassian.net/browse/WIFI-13857

NOTE: This is port of https://github.com/Telecominfraproject/wlan-cloud-ucentralgw/pull/362

Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>
2024-06-19 16:43:47 -04:00
i-chvets
791b72aec4 Merge pull request #110 from Telecominfraproject/WIFI-13597-fix-kafka-producer-using-poll
fix: added flush() for proper shutdown
2024-06-17 09:23:11 -04:00
i-chvets
bb09f919e6 Merge pull request #109 from Telecominfraproject/WIFI-13597-fix-kafka-producer-using-poll
fix: modified kafka manager to use poll in producer
2024-06-13 14:35:18 -04:00
2 changed files with 11 additions and 2 deletions

View File

@@ -9,7 +9,7 @@ fullnameOverride: ""
images:
owsec:
repository: tip-tip-wlan-cloud-ucentral.jfrog.io/owsec
tag: main
tag: v3.2.0-RC1
pullPolicy: Always
# regcred:
# registry: tip-tip-wlan-cloud-ucentral.jfrog.io

View File

@@ -107,7 +107,16 @@ namespace OpenWifi {
NewMessage.partition(0);
NewMessage.payload(Msg->Payload());
Producer.produce(NewMessage);
Producer.poll((std::chrono::milliseconds) 0);
if (Queue_.size() < 100) {
// use flush when internal queue is lightly loaded, i.e. flush after each
// message
Producer.flush();
}
else {
// use poll when internal queue is loaded to allow messages to be sent in
// batches
Producer.poll((std::chrono::milliseconds) 0);
}
}
} catch (const cppkafka::HandleException &E) {
poco_warning(Logger_,