Telecominfraproject/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2026-01-27 02:22:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixes #158

Browse Source
This commit is contained in:
accelerated
2019-01-16 15:09:27 -05:00
parent 05cc8304df
commit dc732445f7
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/kafka_handle_base.cpp
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);
}
}
}