时间戳

首页 > 解决方案 > kafka 控制台消费者抛出 auth SecurityProtocol 错误

apache-kafka - kafka 控制台消费者抛出 auth SecurityProtocol 错误

问题描述

我已经为 Kafka 启用了 Kerberos。我可以使用以下命令生成数据

/usr/hdp/current/kafka-broker/bin/kafka-console-producer.sh --broker-list HOSTNAME:6667 --topic test --producer-property security.protocol=SASL_PLAINTEXT

但是在消费时我面临如下错误

org.apache.kafka.common.KafkaException: 无法构造 kafka 消费者

我正在使用以下命令来消费

/usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --bootstrap-server HOSTNAME:6667 --topic test --consumer-property security.protocol SASL_PLAINTEXT

标签： apache-kafkaapache-zookeeperkerberos

解决方案

如果您指定 setsecurity.protocol使用 SASL，那么您还需要指定：

  • sasl.jaas.config：提供 SASL 凭据
  • sasl.mechanism: 选择 SASL 机制，Kafka 支持GSSAPI(Kerberos), PLAIN, SCRAM-SHA-256,SCRAM-SHA-512和OAUTHBEARER

有关这些设置的详细信息，请参阅http://kafka.apache.org/documentation/#security_sasl_plain_clientconfig。

推荐阅读