卡夫卡 TOPIC_AUTHORIZATION_FAILED

3 回答

• 2

  通过分离 jaas 客户端和 jaas 服务器修复问题。

  kafka_server_jaas.conf

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

  kafka_client_jaas.conf

  KafkaClient {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="alice"
    password="alice-secret";
  };
  

  在同一个终端上，导出 jaas 服务器 conf 文件并启动 kafka broker：

  $ export KAFKA_OPTS="-Djava.security.auth.login.config=/home/user/kafka_2.10-0.10.0.1/kafka_server_jaas.conf"
  $ ./bin/kafka-server-start.sh config/server.properties
  

  在客户端终端上，导出客户端 jaas conf 文件并启动使用者：

  $ export KAFKA_OPTS="-Djava.security.auth.login.config=/home/user/kafka_2.10-0.10.0.1/kafka_client_jaas.conf"
  $ ./bin/kafka-console-consumer.sh --new-consumer --zookeeper localhost:2181 --topic test-topic --from-beginning --consumer.config=config/consumer.properties  --bootstrap-server=localhost:9092
  

  如果您还想生产，请在另一个终端窗口上执行此操作：

  $ export KAFKA_OPTS="-Djava.security.auth.login.config=/home/user/kafka_2.10-0.10.0.1/kafka_client_jaas.conf"
  $ ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test-topic --producer.config=config/producer.properties
  

  回复于 2024-04-28T08:35:32+08:00
• 0

  似乎您创建了一个复制因子为 3 的主题，但您只运行了 1 个代理。尝试使用“--replication-factor 1”创建主题。如果要自动创建主题，您可能还希望将默认复制因子更改为 1(config/server.properties in config/server.properties)。

  回复于 2024-04-28T08:35:32+08:00
• 0

  我在 Kafka v.0.10 中使用 ACL 时遇到了类似的问题。我觉得这个讨论很有帮助。特别是启用授权日志以检查请求的传入用户名是什么以及 ACL 中指定的内容。

  首先检查服务器主管理员是否提供了所需的所有授权。需要允许服务器主体对所有主题，组和群集执行所有类型的授权。最好在 server.properties server.properties 文件中声明管理员。如果这不能解决问题，那么您可以启用授权日志以找出正在为哪种操作定义哪个样本。

  可以通过修改 config 文件夹中的 log4j.properties 来启用授权日志。在 log4j.properties 文件中，将WARN更改为DEBUG并重新启动 kafka-servers。

  log4j.logger.kafka.authorizer.logger=DEBUG, authorizerAppender
  

  这有助于我解决我的问题。希望有所帮助。

  PS：生成的授权日志非常冗长，占用大量空间。所以，记得在完成调试时关闭它。

  回复于 2024-04-28T08:35:32+08:00