diff --git a/src/framework/KafkaManager.cpp b/src/framework/KafkaManager.cpp
index 016b57e0..39e6d6e4 100644
--- 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_,