search

dpkp / kafka-python

Python client for Apache Kafka
http://kafka-python.readthedocs.io/
Apache License 2.0
5.6k stars 1.4k forks source link

no client information at consumer group side #2199

Open IronLung7 opened 3 years ago

IronLung7 commented 3 years ago

Using consumer from kafka-python, there is no client information at consumer group side:

./kafka-consumer-groups.sh --bootstrap-server xxxxxxxx:9092 --describe --group aa Note: This will not show information about old Zookeeper-based consumers.

Consumer group 'aa' has no active members.

TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID topic-a 0 928 928 0 - - -

IronLung7 commented 3 years ago

Using kafka-python==2.0.1, and the client_id is set when initializing consumer.

IronLung7 commented 3 years ago

If using consumer.subscribe(topic_l), Client-id will in consumer group describe. if using consumer.assign(TopicPartition), Client-id will not in consumer group describe.