Description
Using the command:
./kafka-consumer-groups.sh --bootstrap-server=localhost:9092 --describe --group foo-group
If the CONSUMER-ID is too long the delimiter between CONSUMER-ID and HOST disappears.
Output:
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID foobar-1 14 8948049 8948663 614 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer-7c0345f5-4806-4957-be26-eb4b3bd6a9dc/10.2.3.40 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer
Expected output:
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID foobar-1 14 8948049 8948663 614 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer-7c0345f5-4806-4957-be26-eb4b3bd6a9dc /10.2.3.40 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer
I suspect that the formatting rules are incorrect https://github.com/apache/kafka/blob/0.11.0/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala#L137.
Attachments
Issue Links
- Is contained by
-
KAFKA-5526 KIP-175: ConsumerGroupCommand no longer shows output for consumer groups which have not committed offsets
- Resolved