呼哈

0 声望

这家伙太懒，什么都没留下

个人动态
  • 半兽人 回复 呼哈 在 kafka 配置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
    10月前
  • 半兽人 回复 呼哈 在 kafka实战SASL/SCRAM 中 ：

    kafka_client_jaas.conf

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

    运行：

    export KAFKA_OPTS="-Djava.security.auth.login.config=/etc/kafka/kafka_client_jaas.conf"
bin/kafka-console-producer.sh --broker-list localhost:9093 --topic test --producer.config config/producer.properties 

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
    10月前
  • 呼哈 回复 半兽人 在 kafka实战SASL/SCRAM 中 ：

    是的， 我有学习这篇文章！ 这边文章更多的是给topic配置acl权限。我想请教您的是配置了acl的topic启动消费者的命令是什么呢？bin/kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic test 这样的话当然是链接不上的。该怎么更改这个命令呢？ 感谢！！

    10月前
  • 半兽人 回复 呼哈 在 kafka实战SASL/SCRAM 中 ：

    这篇文章应该对你有帮助：kafka认证和acl

    10月前
  • 发表了 kafka 配置acl后该如何启动某topic的消费者  
    10月前
  • 呼哈 回复 半兽人 在 kafka实战SASL/SCRAM 中 ：

    大佬好！ 请问笔记目录下有SASL的各种实战例子，那我们有没有ACL的实战例子呢？
    请教一下如果已经给某topic配置了ACL，想要启动该topic的消费者该在基础命令上加什么呢？ 感谢感谢！！

    10月前
  • 关注了用户 半兽人 · 2年前