https://telecominfraproject.atlassian.net/browse/WIFI-12954

Signed-off-by: stephb9959 <[email protected]>
Telecominfraproject · Sep 22, 2023 · 2f45a69 · 2f45a69
1 parent 78015d2
commit 2f45a69
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/framework/KafkaManager.cpp b/src/framework/KafkaManager.cpp
@@ -103,6 +103,7 @@ namespace OpenWifi {
 					NewMessage.key(Msg->Key());
 					NewMessage.payload(Msg->Payload());
 					Producer.produce(NewMessage);
+					Producer.flush();
 				}
 			} catch (const cppkafka::HandleException &E) {
 				poco_warning(Logger_,