// 三个参数分别为topic, key,valuesend()是异步的,添加到缓冲区立即返回更高效。
只偠配置zookeeper.connect为要加入的集群再启动Kafka进程,就可以让新的机器加入到Kafka集群但是新的机器只针对新的Topic才会起作用,在之前就已经存在的Topic的分区不会自动的分配到新增加的物理机中。为了使新增加的机器可以分担系统压力必须进行消息数据迁移。Kafka提供了kafka-reassign-partitions.sh进行数据迁移
2)检查新增机器的zk信息中主机名是否准确,每个broker都要检查
多个格式:多个用逗号隔开
调用--generate生成迁移计划将reqinfo扩充到broker-id为 0上(这里可根据自己的实际情况定义)
--generate: 根据给予的Topic列表和Broker列表生成迁移计划。generate并不会真正进行消息迁移而是将消息迁移计划计算出来,供execute命令使用
版权声明:本文为博主原创文章未经博主允许不得转载。 /u/article/details/