Skip to content

Commit 114d5be

Browse files
authored
Merge pull request #4 from ClickHouse/get_member_id-crash
Fix crash in get_member_id() if client group is not initialized
2 parents f56b2fe + daa2cd1 commit 114d5be

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/consumer.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -241,6 +241,8 @@ TopicPartitionList Consumer::get_assignment() const {
241241

242242
string Consumer::get_member_id() const {
243243
char* memberid_ptr = rd_kafka_memberid(get_handle());
244+
if (memberid_ptr == nullptr)
245+
return string();
244246
string memberid_string = memberid_ptr;
245247
rd_kafka_mem_free(nullptr, memberid_ptr);
246248
return memberid_string;

0 commit comments

Comments
 (0)