kafka集群重启后节点丢失如何修复

開開新新 发表于: 2020-07-22   最后更新时间: 2020-07-22 09:55:47   2,461 游览

kafka: kafka_2.12-2.2.0

3个broker节点

1、节点丢失了,怎么修复?

screenshot

我原来有三个节点,后来10.147丢了,我重启了一下10.147没用,然后分别重启了10.145和10.146,最后146和147都绑定到一起了,但是145丢了。这种情况怎么让145强制加入呢?

另外我重启每个节点的时候都会提示

WARN Resetting first dirty offset of __consumer_offsets-33 to log start offset 908311 since the checkpointed offset 908307 is invalid.

所以我索引把每个节点的data目录都清空了。

2、从zk收到的信息和manager收到的topic信息不一致是怎么回事? 第二张图片和第一张图片的topic数量不一致,是什么原因造成的呢?

screenshot

发表于 2020-07-22
添加评论

没有强制加入,kafka是根据指定同一个zk,来决定是否为一个集群的,通过broker.id来标识成员(所以不要乱修改)。
根据警告,offset已经落后了,会自行恢复。

另外,你要看具体没有加入进来的“节点”报的什么错误,才能定位问题。

你的答案

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