kafka多个broker低版本的怎么用java查询给定broker上所有的日志目录信息

查看topic创建情况:

上面的有些东西也许还不太清楚,暂放继续试验。需要注意的是topic_1的Leader=2

(4)模拟客户端发送接受消息

需要注意,此时producer将topic发布到了3个broker中现在就有点分布式的概念了。

首先我们根据前面的配置,得到broker(id=0)应该在9092监听,这样就能确定它的PID了

kill之后,再观察做下对比。很明显主要变化在于Isr,以后再汾析

测试下发送消息,接受消息是否收到影响。

可见kafka多个broker的分布式机制,容错能力还是挺好的~

  • producer 消息的生成者即发布消息

  • consumer 消息的消費者,即订阅消息

  • broker kafka多个broker以集群的方式运行可以由一个或多个服务组成,服务即broker

producers通过网络将消息发送到kafka多个broker集群集群向消费者提供消息

}

我要回帖

更多关于 kafka多个broker 的文章

更多推荐

版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。

点击添加站长微信