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

Signed-off-by: stephb9959 <[email protected]>
Telecominfraproject · Sep 22, 2023 · 78015d2 · 78015d2
1 parent 9235495
commit 78015d2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/build b/build
@@ -1 +1 @@
-23
+24
diff --git a/src/framework/KafkaManager.cpp b/src/framework/KafkaManager.cpp
@@ -99,9 +99,10 @@ namespace OpenWifi {
 			try {
 				auto Msg = dynamic_cast<KafkaMessage *>(Note.get());
 				if (Msg != nullptr) {
-					Producer.produce(cppkafka::MessageBuilder(Msg->Topic())
-										 .key(Msg->Key())
-										 .payload(Msg->Payload()));
+					auto NewMessage = cppkafka::MessageBuilder(Msg->Topic());
+					NewMessage.key(Msg->Key());
+					NewMessage.payload(Msg->Payload());
+					Producer.produce(NewMessage);
 				}
 			} catch (const cppkafka::HandleException &E) {
 				poco_warning(Logger_,