呼哈

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
    
    1年前
  • 半兽人 回复 呼哈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
    
    1年前
  • 呼哈 回复 半兽人kafka实战SASL/SCRAM 中 :

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

    1年前
  • 半兽人 回复 呼哈kafka实战SASL/SCRAM 中 :

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

    1年前
  • 呼哈 回复 半兽人kafka实战SASL/SCRAM 中 :

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

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