fix: release 3.2 version update

https://telecominfraproject.atlassian.net/browse/WIFI-14165 Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>
Merge pull request #111 from Telecominfraproject/WIFI-13857-fix-svc-kafka-startup
2025-10-30 02:12:32 +00:00 · 2024-09-30 09:35:21 -04:00 · 2024-06-19 16:59:56 -04:00 · 2024-06-19 16:43:47 -04:00 · 2024-06-17 09:23:11 -04:00 · 2024-06-13 14:35:18 -04:00
2 changed files with 11 additions and 2 deletions
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -1,5 +1,5 @@
 cmake_minimum_required(VERSION 3.13)
-project(owsec VERSION 3.1.0)
+project(owsec VERSION 3.2.0)

 set(CMAKE_CXX_STANDARD 17)

--- a/src/framework/KafkaManager.cpp
+++ b/src/framework/KafkaManager.cpp
@@ -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_,
Author	SHA1	Message	Date
Ivan Chvets	1977ecdfb7	fix: release 3.2 version update https://telecominfraproject.atlassian.net/browse/WIFI-14165 Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>	2024-09-30 09:35:21 -04: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