mirror of
https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
synced 2025-11-01 19:27:59 +00:00
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
This commit is contained in:
@@ -107,7 +107,16 @@ namespace OpenWifi {
|
|||||||
NewMessage.partition(0);
|
NewMessage.partition(0);
|
||||||
NewMessage.payload(Msg->Payload());
|
NewMessage.payload(Msg->Payload());
|
||||||
Producer.produce(NewMessage);
|
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) {
|
} catch (const cppkafka::HandleException &E) {
|
||||||
poco_warning(Logger_,
|
poco_warning(Logger_,
|
||||||
|
|||||||
Reference in New Issue
Block a user