scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-01 19:18:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #281 from ClickHouse-Extras/fix_failover

Browse Source 
Fix for failover issue.
This commit is contained in:
Matias Fontanini
2021-06-02 16:04:02 -07:00
committed by GitHub
parent 57a599d99c dabb2d3aa8
commit dd3966fb45
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/consumer.cpp
View File

@@ -124,15 +124,9 @@ void Consumer::unsubscribe() {
void Consumer::assign(const TopicPartitionList& topic_partitions) { void Consumer::assign(const TopicPartitionList& topic_partitions) {
rd_kafka_resp_err_t error; rd_kafka_resp_err_t error;
if (topic_partitions.empty()) { TopicPartitionsListPtr topic_list_handle = convert(topic_partitions);
error = rd_kafka_assign(get_handle(), nullptr); error = rd_kafka_assign(get_handle(), topic_list_handle.get());
check_error(error); check_error(error, topic_list_handle.get());
}
else {
TopicPartitionsListPtr topic_list_handle = convert(topic_partitions);
error = rd_kafka_assign(get_handle(), topic_list_handle.get());
check_error(error, topic_list_handle.get());
}
} }
void Consumer::unassign() { void Consumer::unassign() {