请问如果已经给某topic配置了ACL,想要启动该topic的消费者该在基础命令上加什么呢?或者它的正确命令该是什么呢?
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
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
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
你的答案