From dc732445f7569e53f9e90a7f36285089d14b4b87 Mon Sep 17 00:00:00 2001
From: accelerated <>
Date: Wed, 16 Jan 2019 15:09:27 -0500
Subject: [PATCH] Fixes #158

---
 src/kafka_handle_base.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/kafka_handle_base.cpp b/src/kafka_handle_base.cpp
index bba6e14a..c93139c9 100644
--- a/src/kafka_handle_base.cpp
+++ b/src/kafka_handle_base.cpp
@@ -241,7 +241,7 @@ void KafkaHandleBase::check_error(rd_kafka_resp_err_t error,
         //check if any partition has errors
         for (int i = 0; i < list_ptr->cnt; ++i) {
             if (list_ptr->elems[i].err != RD_KAFKA_RESP_ERR_NO_ERROR) {
-                throw HandleException(error);
+                throw HandleException(list_ptr->elems[i].err);
             }
         }
     }