Add comment regarding flushing producer

This commit is contained in:
Matias Fontanini
2018-10-19 08:41:36 -07:00
committed by GitHub
parent 2b66fd3a22
commit b2ba4cbfa3

View File

@@ -74,6 +74,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
*/
class CPPKAFKA_API Producer : public KafkaHandleBase {