From b5a7c709939d170666bd03337cdf083244f4e0fa Mon Sep 17 00:00:00 2001
From: Matias Fontanini <matias.fontanini@gmail.com>
Date: Sun, 23 Apr 2017 14:12:00 -0700
Subject: [PATCH] Expand description of BufferedProducer

---
 include/cppkafka/utils/buffered_producer.h | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/include/cppkafka/utils/buffered_producer.h b/include/cppkafka/utils/buffered_producer.h
index 2cec099..a47f8e8 100644
--- a/include/cppkafka/utils/buffered_producer.h
+++ b/include/cppkafka/utils/buffered_producer.h
@@ -24,6 +24,9 @@ namespace cppkafka {
  * produced messages (either in a buffer or non buffered way) are acknowledged by the kafka
  * brokers.
  *
+ * When producing messages, this class will handle cases where the producer's queue is full so it\
+ * will poll until the production is successful.
+ *
  * This class is not thread safe.
  */
 template <typename BufferType>
@@ -167,7 +170,7 @@ void BufferedProducer<BufferType>::flush() {
 template <typename BufferType>
 void BufferedProducer<BufferType>::wait_for_acks() {
     messages_acked_ = 0;
-    while (messages_acked_ != expected_acks_) {
+    while (messages_acked_ < expected_acks_) {
         try {
             producer_.flush();
         }