From d77e7466b821ada832e932326c9f33981e7b135c Mon Sep 17 00:00:00 2001
From: Alex Damian <alex.damian@gmail.com>
Date: Sat, 6 Oct 2018 12:28:45 -0400
Subject: [PATCH] changed assert with if statement (#116)

---
 include/cppkafka/utils/buffered_producer.h | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/include/cppkafka/utils/buffered_producer.h b/include/cppkafka/utils/buffered_producer.h
index ffeff53..cfba871 100644
--- a/include/cppkafka/utils/buffered_producer.h
+++ b/include/cppkafka/utils/buffered_producer.h
@@ -849,9 +849,10 @@ void BufferedProducer<BufferType>::on_delivery_report(const Message& message) {
     if (tracker) {
         tracker->should_retry_.set_value(should_retry);
     }
-    // Decrement the expected acks
-    --pending_acks_;
-    assert(pending_acks_ != (size_t)-1); // Prevent underflow
+    // Decrement the expected acks and check to prevent underflow
+    if (pending_acks_ > 0) {
+        --pending_acks_;
+    }
 }
 
 } // cppkafka