格文

0 声望

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

个人动态
  • 格文 回复 半兽人kafka中SASL/PLAIN与acl配合使用的问题 中 :

    您好,我之前是在consumer和producer的启动脚本中都加了下面这一段

    if ["x$KAFKA_OPTS"="x"]; then
       export KAFKA_OPTS="-Djava.security.auth.login.config=$KAFKA_HOME/kafka_client_jaas.conf"
    fi
    echo -e $KAFKA_OPTS
    

    echo打印出的KAFKA_OPTS也正确,请问这样设置jvm正确吗?

    7年前
  • 半兽人 回复 格文kafka中SASL/PLAIN与acl配合使用的问题 中 :

    你启动消费的时候,需要把它带到jvm中。

    7年前
  • 格文 回复 半兽人kafka中SASL/PLAIN与acl配合使用的问题 中 :

    您好,我这样试了下,现在使用consumer的时候,会报

    org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to access group: test-group
    

    然后我使用

    bin/kafka-acls.sh --authorizer-properties zookeeper.connect ··· --add --allow-principal User:alice --consumer --topic test --group test-group
    

    为用户alice授权了,可是执行consumer后还是上述的报错。
    请问是否我还有哪里没有配置正确?

    7年前