thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

contrib: update cppkafka to v0.4.1@9c5ea0e3

Browse Source
This commit is contained in:
Ilya Golshtein 2024-03-09 07:52:23 +00:00
parent 018316c78a
commit 939554ec0a
2 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
contrib/cppkafka vendored

@ -1 +1 @@
Subproject commit 5a119f689f8a4d90d10a9635e7ee2bee5c127de1 Subproject commit 9c5ea0e332486961e612deacc6e3f0c1874c688d

12
src/Storages/Kafka/KafkaConsumer.cpp
View File

@ -599,24 +599,14 @@ void KafkaConsumer::setExceptionInfo(const std::string & text, bool with_stacktr
exceptions_buffer.push_back({enriched_text, static_cast<UInt64>(Poco::Timestamp().epochTime())}); exceptions_buffer.push_back({enriched_text, static_cast<UInt64>(Poco::Timestamp().epochTime())});
} }
/*
* Needed until
* https://github.com/mfontanini/cppkafka/pull/309
* is merged,
* because consumer->get_member_id() contains a leak
*/
std::string KafkaConsumer::getMemberId() const std::string KafkaConsumer::getMemberId() const
{ {
if (!consumer) if (!consumer)
return ""; return "";
char * memberid_ptr = rd_kafka_memberid(consumer->get_handle()); return consumer->get_member_id();
std::string memberid_string = memberid_ptr;
rd_kafka_mem_free(nullptr, memberid_ptr);
return memberid_string;
} }
KafkaConsumer::Stat KafkaConsumer::getStat() const KafkaConsumer::Stat KafkaConsumer::getStat() const
{ {
KafkaConsumer::Stat::Assignments assignments; KafkaConsumer::Stat::Assignments assignments;