该报错是由于kafka消费者组缺少ACL授权导致的。
可以通过如下命令赋予消费者组XXX读取权限:
./kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181/kafka --add --allow-principal User:UserName --operation Read --group XXX
本页目录
该报错是由于kafka消费者组缺少ACL授权导致的。
可以通过如下命令赋予消费者组XXX读取权限:
./kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181/kafka --add --allow-principal User:UserName --operation Read --group XXX