I am using a kafka consumer where the partitions are assigned using maually
instead of automatic group assignment using a code similar to "consumer.
assign(<Partitions>);"

In this case bin/kafka-consumer-groups fails with the message "Consumer
group `my_group1` does not exist or is rebalancing"


On debugging I found that the AdminClient.scals is returning a empty list
for the group summary with "GroupSummary(Dead,,,List())" status.

The command works when I use a consumer group with automatic partition
assignment.

Can someone from kafka-dev confirm if this is the expected behaviour ?

Thanks,
Prabhu

Reply via email to