查看topic创建情况:
上面的有些东西也许还不太清楚,暂放继续试验。需要注意的是topic_1的Leader=2
需要注意,此时producer将topic发布到了3个broker中现在就有点分布式的概念了。
首先我们根据前面的配置,得到broker(id=0)应该在9092监听,这样就能确定它的PID了
kill之后,再观察做下对比。很明显主要变化在于Isr,以后再汾析
测试下发送消息,接受消息是否收到影响。
可见kafka多个broker的分布式机制,容错能力还是挺好的~
producer 消息的生成者即发布消息
consumer 消息的消費者,即订阅消息
broker kafka多个broker以集群的方式运行可以由一个或多个服务组成,服务即broker
producers通过网络将消息发送到kafka多个broker集群集群向消费者提供消息
}版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。