我们正面临一个安全问题 GroupAuthorizationException
在Kafka主题上消费。
在日志中,我可以看到它是指一个默认的消费者组。
以下是我的kafkauser cr,他将组定义为快乐用户-消费者组:
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaUser
metadata:
name: happy-user-consumer
labels:
strimzi.io/cluster: cluster1
spec:
authentication:
type: tls
authorization:
type: simple
acls:
- resource:
type: topic
name: happy-topic
patternType: literal
operation: Read
host: "*"
- resource:
type: topic
name: happy-topic
patternType: literal
operation: Describe
host: "*"
- resource:
type: group
name: happy-user-consumer-group
patternType: literal
operation: Read
host: "*"
错误:org.apache.kafka.common.errors.groupauthorizationexception:无权访问组:console-consumer-4369
我不确定它指向的是控制台消费者群体。
另外,使用下面的脚本,我无法列出消费者组。我们还有其他方法可以查看消费群体的列表吗?
./bin/kafka-consumer-groups.sh --bootstrap-server kafka.viswa.com:9094 --command-config /tmp/prod/consumer.properties --list
这里需要帮助。
1条答案
按热度按时间b4wnujal1#
您使用的cli命令是正确的。也许你没有消费者群体的名单?
那么你是如何理解这个主题的呢?也通过cli?然后你就可以用这样的脚本了
强制消费者使用特定的消费者组名称。如果你没有指定
--group
Kafka使用的是默认组名,console-consumer-4369
对你来说。希望这对你有帮助,我会感谢你的反馈。
祝你好运,斯蒂芬