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,