如何用Java向kafka发送json消息 命令数据

       只偠配置zookeeper.connect为要加入的集群再启动Kafka进程,就可以让新的机器加入到Kafka集群但是新的机器只针对新的Topic才会起作用,在之前就已经存在的Topic的分区不会自动的分配到新增加的物理机中。为了使新增加的机器可以分担系统压力必须进行消息数据迁移。Kafka提供了kafka-reassign-partitions.sh进行数据迁移

2)检查新增机器的zk信息中主机名是否准确,每个broker都要检查

#首先手动创建需要遷移的topic

多个格式:多个用逗号隔开

调用--generate生成迁移计划将reqinfo扩充到broker-id为 0上(这里可根据自己的实际情况定义)

--generate: 根据给予的Topic列表和Broker列表生成迁移计划。generate并不会真正进行消息迁移而是将消息迁移计划计算出来,供execute命令使用

// 三个参数分别为topic, key,valuesend()是异步的,添加到缓冲区立即返回更高效。

版权声明:本文为博主原创文章未经博主允许不得转载。 /u/article/details/

消息队列在java EE级开发是很常用到的工具之一在众多消息队列当中,active mq与kafka相对比较受开发者的喜爱那么kafka是怎样实現消息的发送与接收呢?这里我们的消息通过一个实体类对象来进行封装前提是你服务器上已经搭建好kafka环境,整个代码如下:

我要回帖

更多关于 kafka发送json 的文章

 

随机推荐