我正在创建使用
Kafka-console-consumer.sh
.
如果我用zookeeper创建了一个旧的消费者组,那么我可以看到在列出消费者时创建了消费者组。
老消费群体
kafka-console-consumer.sh --zookeeper localhost:2181 --security-protocol SASL_PLAINTEXT --topic test --consumer-property group.id=old_consumer_group
kafka-consumer-groups.sh --list --zookeeper d9lcwphd1m1.labcorp.ad.ctc:2181
但是,当我创建一个新的消费群时。我在名单上看不到。
kafka-console-consumer.sh --bootstrap-server localhost:6667 --security-protocol SASL_PLAINTEXT --topic test --consumer-property group.id=new_consumer_group
列表显示为空
gaurang.shah@hadoop_dev]$ kafka-consumer-groups.sh --bootstrap-server localhost:6667 --security-protocol SASL_PLAINTEXT --list
Note: This will not show information about old Zookeeper-based consumers.
[2019-03-05 15:07:45,182] WARN [Principal=gaurang.shah@abc.com]: TGT renewal thread has been interrupted and will exit. (org.apache.kafka.common.security.kerberos.KerberosLogin)
我检查了ACL并找到了这个,不确定它是否只适用于旧组还是同时适用于旧组?
Current ACLs for resource `Group:*`:
User:* has Allow permission for operations: All from hosts: *
User:Alice has Allow permission for operations: All from hosts: *
