From 0d54acbc6419a513d0f5577735165b124b84b574 Mon Sep 17 00:00:00 2001 From: Matias Fontanini Date: Fri, 19 Oct 2018 08:42:10 -0700 Subject: [PATCH] Flush producer in example --- examples/producer_example.cpp | 3 +++ 1 file changed, 3 insertions(+) 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(); }