From b2ba4cbfa378c64fa6d2de1bbc57a4063d24ab35 Mon Sep 17 00:00:00 2001 From: Matias Fontanini Date: Fri, 19 Oct 2018 08:41:36 -0700 Subject: [PATCH] Add comment regarding flushing producer --- include/cppkafka/producer.h | 3 +++ 1 file changed, 3 insertions(+) diff --git a/include/cppkafka/producer.h b/include/cppkafka/producer.h index 6877acf..0c2edc4 100644 --- a/include/cppkafka/producer.h +++ b/include/cppkafka/producer.h @@ -73,6 +73,9 @@ class Message; * * // Write using a key on a fixed partition (42) * producer.produce(MessageBuilder("some_topic").partition(42).key(key).payload(payload)); + * + * // Flush the produced messages + * producer.flush(); * * \endcode */