kafka: kafka_2.12-2.2.0
3个broker节点
1、节点丢失了,怎么修复?
我原来有三个节点,后来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数量不一致,是什么原因造成的呢?
没有强制加入,kafka是根据指定同一个
zk
,来决定是否为一个集群的,通过broker.id
来标识成员(所以不要乱修改)。根据警告,offset已经落后了,会自行恢复。
另外,你要看具体没有加入进来的“节点”报的什么错误,才能定位问题。
你的答案