kafka controller node 和其他 node 分区后,kafka 如何处理?
回答·3
最热
最新
- 两种情况 其他 node 是新增的 node,然后由 node 变更引起的分区变化,这个时候需要对这些分区进行重新分配管理,controller node 会有通过 zk 监控到变化,然后重新计算分区以及副本的同步计算 如果其他 node 是由于分区数量的调整,控制节点监控到 zk 的分区变化事件,对应的事件处理将那么每个节点上都会重新计算各个 topic 的分区
- 创建不同主题 然后分别监控和拦截
- 等我学会了再来告诉你