I recently started using using kafka-utils v2.3.0 against a 3 node kafka 1.0 cluster. I am trying to do a basic operation of listing all the consumer groups in my cluster. The kafka-consumer-groups.sh utility returns my groups, but:
kafka-consumer-manager --cluster-type=internal --cluster-name=prelease --vvverbose list_groups returns 0 groups with the message:
Consumer Groups:
0 groups found for cluster prelease of type internal
My initial thought was that I had mis-configured something, but I could not figure it out myself.
The get_topic_watermark command on the other hand works perfectly with my configs:
I recently started using using kafka-utils v2.3.0 against a 3 node kafka 1.0 cluster. I am trying to do a basic operation of listing all the consumer groups in my cluster. The
kafka-consumer-groups.sh
utility returns my groups, but:kafka-consumer-manager --cluster-type=internal --cluster-name=prelease --vvverbose list_groups
returns 0 groups with the message:My initial thought was that I had mis-configured something, but I could not figure it out myself.
The
get_topic_watermark
command on the other hand works perfectly with my configs:Appreciate inputs.