Merge pull request #159 from accelerated/check_error_fix

Fix error check in partition list
This commit is contained in:
Matias Fontanini
2019-01-16 12:27:57 -08:00
committed by GitHub

View File

@@ -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);
}
}
}