kafka消费时报错

作者 bona | 发布于2018年08月15日 | 阅读数:463

消费kafka中的topic时,如果分区大于1就会报错: Attempt to fetch offsets for partition vipInfo-1 failed due to obsolete leadership information, retrying.如果分区是1的话就可以正常消费?有人遇到过这个问题吗?
已邀请:

JackGe

赞同来自:

这个错误信息是在Fetcher类handleListOffsetResponse方法的675行
else if (error == Errors.NOT_LEADER_FOR_PARTITION) {
log.debug("Attempt to fetch offsets for partition {} failed due to obsolete leadership information, retrying.",
topicPartition);
future.raise(error);
}
意思是该topic partition没有找到leader,你需要检查下你创建的topic所有partition的是否正常,使用kafka命令
kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic topicName

要回复问题请先登录注册