033

0 声望

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

个人动态
  • 033 回复 半兽人kafka ACL权限控制相关问题 中 :
    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)
    

    现在是这种问题 请教大神 谢谢

    5年前
  • 033 回复 半兽人kafka认证和acl 中 :

    请教 我的设置SASL+ACL 后 怎么收不到信息了 发信息也不报错 请问怎么排查

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