我在SASL_PLAINTEXT模式下使用Kafka2.1,并在创建用户和组所需的主题上控制ACL。那么,如何在运行集群中创建用户呢?我知道我可以使用kafka-consumer-groups.sh创建和列出组。但是,当我试图列出组时,它会引发Failed to find brokers to send ListGroups异常。
我正在开发一个Kafka流应用程序,它将读取来自输入Kafka主题的消息,并过滤不必要的数据并将其推送到输出Kafka主题。: Not authorized to access group: QC-NormalizedEventProcessor-v1.0.0
我们的Kafka团队对"group.id“给予了必要的许可,使用这个相同的”组id“,我可以使用其他Kafka消费者应用程序和I按照我在"application.id&quo