本篇文章给大家分享的是有关怎样验证kafka集群高可用,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。
情形1:建一个topic:mytopic共3个分区,3个ReplicationFactor
bin/kafka-topics.sh –create –zookeeper 192.168.135.130:2181,192.168.135.129:2181,192.168.135.131:2181 –replication-factor 3 –partitions 3 –topic mytopic
Topic:mytopic PartitionCount:3 ReplicationFactor:3 Configs:
Topic: mytopic Partition: 0 Leader: 1 Replicas: 1,2,0 Isr: 1,2,0
Topic: mytopic Partition: 1 Leader: 2 Replicas: 2,0,1 Isr: 2,0,1
Topic: mytopic Partition: 2 Leader: 0 Replicas: 0,1,2 Isr: 0,1,2
如果挂掉分区0对应的1号节点,则可以正常发送消息
情形2:建一个topic:yourtopic共3个分区,1个ReplicationFactor
bin/kafka-topics.sh开发云主机域名 开发云主机域名–create –zookeeper 192.168.135.130:2181,192.168.135.129:2181,192.168.135.131:2181 –replication-factor 1 –partitions 3 –topic yourtopic
Topic:yourtopic PartitionCount:3 ReplicationFactor:1 Configs:
Topic: yourtopic Partition: 0 Leader: 2 Replicas: 2 Isr: 2
Topic: yourtopic Partition: 1 Leader: 0 Replicas: 0 Isr: 0
Topic: y开发云主机域名ourtopic Partition: 2 Leader: 1 Replicas: 1 Isr: 1
如果挂掉分区0对应的2号节点,则不能正常发送消息,报错:Error: partition 0 does not have a leader. Skip getting offsets
以上就是怎样验证kafka集群高可用,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注开发云行业资讯频道。
本文从转载,原作者保留一切权利,若侵权请联系删除。
《怎样验证kafka集群高可用》来自互联网同行内容,若有侵权,请联系我们删除!