kafka 配置acl后该如何启动某topic的消费者

呼哈 发表于: 2023-07-17   最后更新时间: 2023-07-17 18:57:01   389 游览

请问如果已经给某topic配置了ACL,想要启动该topic的消费者该在基础命令上加什么呢?或者它的正确命令该是什么呢?

发表于 2023-07-17
添加评论

ACL可以设置各种黑白名单、限制ip等,如果你是角色的情况,可以通过一下方式运行消费者:

kafka_client_jaas.conf

KafkaClient {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="alice"
};

运行:

export KAFKA_OPTS="-Djava.security.auth.login.config=/etc/kafka/kafka_client_jaas.conf"
bin/kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic test --consumer.config config/consumer.properties
你的答案

查看kafka相关的其他问题或提一个您自己的问题