From fd98ebeec970f5841bfbf70b039650b4e6475f69 Mon Sep 17 00:00:00 2001 From: wzl12356 Date: Mon, 7 Mar 2022 16:13:49 +0800 Subject: [PATCH] kafka: delete useless sasl_buf --- src/protocol/KafkaDataTypes.h | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/protocol/KafkaDataTypes.h b/src/protocol/KafkaDataTypes.h index f419cd71..c57657ad 100644 --- a/src/protocol/KafkaDataTypes.h +++ b/src/protocol/KafkaDataTypes.h @@ -630,7 +630,6 @@ public: private: kafka_config_t *ptr; std::atomic *ref; - std::string sasl_buf; }; class KafkaRecord @@ -1388,10 +1387,10 @@ public: return this->coordinator; } - int run_assignor(KafkaMetaList *meta_list, KafkaMetaList *alien_meta_list, + int run_assignor(KafkaMetaList *meta_list, KafkaMetaList *alien_meta_list, const char *protocol_name); - void add_subscriber(KafkaMetaList *meta_list, + void add_subscriber(KafkaMetaList *meta_list, std::vector *subscribers); static int kafka_range_assignor(kafka_member_t **members,