本篇文章给大家分享的是有关怎样验证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:mytopicPartitionCount:3ReplicationFactor:3Configs:
Topic: mytopicPartition: 0Leader: 1Replicas: 1,2,0Isr: 1,2,0
Topic: mytopicPartition: 1Leader: 2Replicas活动:慈云数据爆款香港服务器,CTG+CN2高速带宽、快速稳定、平均延迟10+ms 速度快,免备案,每月仅需19元!! 点击查看: 2,0,1Isr: 2,0,1
Topic: mytopicPartition: 2Leader: 0Replicas: 0,1,2Isr: 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:yourtopicPartitionCount:3ReplicationFactor:1Configs:
Topic: yourtopicPartition: 0Leader: 2Replicas: 2Isr: 2
Topic: yourtopicPartition: 1Leader: 0Replicas: 0Isr: 0
Topic: y开发云主机域名ourtopicPartition: 2Leader: 1Replicas: 1Isr: 1
如果挂掉分区0对应的2号节点,则不能正常发送消息,报错:Error: partition 0 does not have a leader. Skip getting offsets
以上就是怎样验证kafka集群高可用,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注开发云行业资讯频道。
本文从转载,原作者保留一切权利,若侵权请联系删除。
《怎样验证kafka集群高可用》来自互联网同行内容,若有侵权,请联系我们删除!
还没有评论,来说两句吧...