kerberos认证下kafka报错Bootstrap broker host:ip (id: -1 rack: null) disconnected

开启了kerberos认证后kafka运行kafka-console-producer.sh和kafka-console-consumer.sh报错Bootstrap broker host:ip (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)编辑$KAFKA_HOME/config/ 下的prod

董不懂22

13037人浏览 · 2021-03-14 10:03:05

董不懂22 · 2021-03-14 10:03:05 发布

开启了kerberos认证后kafka运行kafka-console-producer.sh和kafka-console-consumer.sh报错
Bootstrap broker host:ip (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

编辑$KAFKA_HOME/config/ 下的producer.properties和consumer.properties文件，在末尾添加认证方式

sasl.mechanism=GSSAPI
security.protocol=SASL_PLAINTEXT
sasl.kerberos.service.name=kafka

运行脚本时指定配置文件

bin/kafka-console-producer.sh --broker-list host:ip --topic test --producer.config config/producer.properties

bin/kafka-console-consumer.sh --bootstrap-server host:ip --topic test --from-beginning --consumer.config config/consumer.properties