diff --git a/examples/producer_example.cpp b/examples/producer_example.cpp index 37e1548..2dcb04f 100644 --- a/examples/producer_example.cpp +++ b/examples/producer_example.cpp @@ -75,4 +75,7 @@ int main(int argc, char* argv[]) { // Actually produce the message we've built producer.produce(builder); } + + // Flush all produced messages + producer.flush(); }