diff --git a/build b/build index b3935607..cabf43b5 100644 --- a/build +++ b/build @@ -1 +1 @@ -23 \ No newline at end of file +24 \ No newline at end of file diff --git a/src/framework/KafkaManager.cpp b/src/framework/KafkaManager.cpp index d32833ed..016b57e0 100644 --- a/src/framework/KafkaManager.cpp +++ b/src/framework/KafkaManager.cpp @@ -99,9 +99,10 @@ namespace OpenWifi { try { auto Msg = dynamic_cast(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_,