kafka: delete useless sasl_buf

This commit is contained in:
wzl12356
2022-03-07 16:13:49 +08:00
parent b4b85e3fc1
commit fd98ebeec9
+2 -3
View File
@@ -630,7 +630,6 @@ public:
private:
kafka_config_t *ptr;
std::atomic<int> *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<KafkaMetaSubscriber> *subscribers);
static int kafka_range_assignor(kafka_member_t **members,