我现在在集群中有4个Kafka节点。Kafka1是旧的,有所有的数据和它的控制器Kafka2,3,4是新的,没有数据
数据不断地向Kafka1写入和读取
我可以这样做吗:
将dns kafka1更改为kafka4(这是群集-数据写入正确吗?)
启动kafka-resign-partitions.sh,将数据从kafka1移动到kafka4
关闭Kafka1
向主题添加副本
是这样吗?还是更好的方法?
我现在在集群中有4个Kafka节点。Kafka1是旧的,有所有的数据和它的控制器Kafka2,3,4是新的,没有数据
数据不断地向Kafka1写入和读取
我可以这样做吗:
将dns kafka1更改为kafka4(这是群集-数据写入正确吗?)
启动kafka-resign-partitions.sh,将数据从kafka1移动到kafka4
关闭Kafka1
向主题添加副本
是这样吗?还是更好的方法?
1条答案
按热度按时间5vf7fwbs1#
听起来,虽然您现在有几个代理,但所有分区仍然只在旧代理上。
传播这种用法的最好方法是使用重新分配脚本
kafka-reassign-partitions.sh
正如你所暗示的。这将允许您移动一些关于新代理的主题。同时,可以为主题添加副本。有多个副本提供了保证,例如,在代理崩溃的情况下,您仍然有在线副本。