broker.id=1
port=9092
advertised.listeners=SASL_PLAINTEXT://10.150.26.172:9092
listeners=SASL_PLAINTEXT://10.150.26.172:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
super.users=user:kafka
advertised.host.name=10.150.26.172
advertised.port=9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=/data/kafka/logs
num.partitions=3
default.replication.factor=3
num.recovery.threads.per.data.dir=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
zookeeper.connect=10.150.26.171:2181,10.150.26.172:2181,10.150.26.173:2181
zookeeper.connection.timeout.ms=6000
delete.topic.enable=true
bootstrap.servers=10.150.26.172:9092
compression.type=none
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
zookeeper.connect=10.150.26.171:2181,10.150.26.172:2181,10.150.26.173:2181
zookeeper.connection.timeout.ms=6000
group.id=test-kkk
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
bin/kafka-acls.sh --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=10.150.26.171:2181,10.150.26.172:2181,10.150.26.173:2181 --add --allow-principal User:hue --operation Read --topic ssssss --group test-kkk
bin/kafka-acls.sh --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=10.150.26.171:2181,10.150.26.172:2181,10.150.26.173:2181 --add --allow-principal User:hive --operation Write --topic ssssss
[2019-01-21 16:04:07,560] WARN Error while fetching metadata with correlation id 35 : {ssssss=TOPIC_AUTHORIZATION_FAILED} (org.apache.kafka.clients.NetworkClient)
现在是这种问题 请教大神 谢谢