mirror of
https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git
synced 2025-11-21 20:24:49 +00:00
Flush producer in example
This commit is contained in:
@@ -75,4 +75,7 @@ int main(int argc, char* argv[]) {
|
|||||||
// Actually produce the message we've built
|
// Actually produce the message we've built
|
||||||
producer.produce(builder);
|
producer.produce(builder);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Flush all produced messages
|
||||||
|
producer.flush();
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user