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

【问题标题】：kafka console consumer throws auth SecurityProtocol errorkafka 控制台消费者抛出 auth SecurityProtocol 错误
【发布时间】：2019-11-21 22:24:52
【问题描述】：

我为 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-kafka apache-zookeeper kerberos

【解决方案1】：

如果您指定 set security.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。

【讨论】：

我已经尝试过使用 Java API，它正在工作。仅使用 Kafka 控制台时，我面临上述错误
现在它也可以工作了。问题是我在安全之后没有提到'='。 protocol SASL_PLAINTEXT 实际命令为 /usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --bootstrap-server HOSTNAME:6667 --topic test --consumer-property security.protocol=SASL_PLAINTEXT