kafka rest之消费组ACL

Consumer group ACL of kafka rest

使用kafka rest消费消息时会检查消费组ACL吗? 我将 kafka-rest 配置为:

zookeeper.connect=localhost:2181
bootstrap.servers=SASL_PLAINTEXT://localhost:9093
client.security.protocol=SASL_PLAINTEXT
client.sasl.mechanism=PLAIN

但是没有检查消费者组ACL。 由于 kafka broker 中的消息被读取为匿名。 这是由 PLAINTEXT 使用的,但我已经配置了 SASL_PLAINTEXT.

对于 Kafka 休息代理,将检查的 ACL 是针对用户 运行 休息代理。除非您进行一些代码更改或使用合流的安全插件,否则不是用户将请求提交给其余代理。