kafka安装kerberos后启动consumer报错 WARN Error while fetching metadata with correlation id 3 : {xdfjc1=LEADER_NOT_AVAILABLE}

我是谁 发表于: 2017-01-16   最后更新时间: 2017-01-16 10:44:00   12,545 游览

[2017-01-16 10:04:03,624] WARN Bootstrap broker ws-node02:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:03,627] WARN Bootstrap broker ws-node01:9092 disconnected (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:03,650] WARN Error while fetching metadata with correlation id 3 : {xdfjc1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:03,762] WARN Error while fetching metadata with correlation id 4 : {xdfjc1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:03,878] WARN Error while fetching metadata with correlation id 5 : {xdfjc1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:03,990] WARN Error while fetching metadata with correlation id 6 : {xdfjc1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:04,102] WARN Error while fetching metadata with correlation id 7 : {xdfjc1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:04,215] WARN Error while fetching metadata with correlation id 8 : {xdfjc1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-01-16 10:04:04,328] WARN Error while fetching metadata with correlation id 9 : {xdfjc1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

kafka
发表于 2017-01-16
我是谁
添加评论

zookeeper什么版本

回复
回答于 7年前
半兽人
我是谁 -> 半兽人 7年前

zookeeper版本是3.4.5-cdh5.5.1，目前这个错误不再报了，主要是对照你的实战笔记做了下修改。但是在启动producer后尝试发送消息时会报错如下，而且consumer那端也接收不到消息。

[root@ws-node01 kafka]# ./producer.sh 
aaa
[2017-01-17 14:56:17,058] ERROR Error when sending message to topic xdfjc1 with key: null, value: 3 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for xdfjc1-0 due to 1509 ms has passed since batch creation plus linger time

其中producer.sh脚本内容如下：

#!/bin/sh
export KAFKA_OPTS="-Djava.security.krb5.conf=/etc/krb5.conf -Djava.security.auth.login.config=/opt/kafka/kafka/config/kafka_client_jaas.conf"
kafka-console-producer.sh --broker-list ws-node01:9092,ws-node02:9092,ws-node03:9092 --topic xdfjc1 --producer.config ./config/producer.properties
1 0 回复
我是谁 -> 半兽人 7年前

目前已经可以了，谢谢啦

0 1 回复
半兽人 -> 我是谁 7年前

恭喜！

0 0 回复

你好，我也碰到这个问题了，你是怎么解决的啊~

0 0 回复

怎么搞定的？

回复
回答于 7年前
Always
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。