时间戳

首页 > 解决方案 > Kafka producer/consuper 主题未授权

apache-kafka - Kafka producer/consuper 主题未授权

问题描述

每当我尝试将 kafka 连接到生产者/消费者时，我都会收到“未授权主题 [test2]”

如果我关闭授权，我将成功通过身份验证，因此身份验证有效，只有授权无效。

使用 kafka.security.auth.SimpleAclAuthorizer 的 ACL 授权不起作用。

配置/server.properties

authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
listeners=SASL_PLAINTEXT://kafka3:9092
security.inter.broker.protocol= SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
delete.topic.enable=false

日志/kafka-授权者

[2019-04-06 13:24:05,693] DEBUG No acl found for resource Topic:LITERAL:test2, authorized = false (kafka.authorizer.logger) [2019-04-06 13:24:05,695] INFO Principal = User:alice is Denied Operation = Describe from host = 10.0.9.20 on resource = Topic:LITERAL:test2(kafka.authorizer.logger)uper.users=User:admin

服务器的 jaas 文件：

KafkaServer {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="admin"
    password="admin"
    user_admin="admin"
    user_alice="alice";
};

bin/kafka-server-start.sh

$base_dir/kafka-run-class.sh $EXTRA_ARGS -Djava.security.auth.login.config=$base_dir/../config/jaas-kafka-server.conf kafka.Kafka "$@"

acl 输出：

Current ACLs for resource `Topic:LITERAL:test2`:
    User:alice has Allow permission for operations: Write from hosts: *

标签： apache-kafka

解决方案

用户alice当前仅被授权访问Write该主题。您可能还希望添加 ACLDescribe并Read能够正确生成和使用现有主题。

该kafka-acls工具提供了方便的选项--consumer以及--producer将 ACL 添加到主题时。否则，您可以使用--operation添加特定操作，例如Describe. 通过添加Describe，您将删除当前在 中看到的日志logs/kafka-authorizer。

推荐阅读