Merge pull request #159 from accelerated/check_error_fix

Fix error check in partition list
mfontanini · Jan 16, 2019 · fb4c5ed · fb4c5ed
2 parents 05cc830 + dc73244
commit fb4c5ed
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);
             }
         }
     }