您好,我之前是在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正确吗?
您好,我这样试了下,现在使用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后还是上述的报错。
请问是否我还有哪里没有配置正确?