Kafka容错性测试

1. 查看topic信息(“副本”是为该分区复制日志的节点列表，无论它们是引导者还是当前处于活动状态，“ isr”是“同步”副本的集合。这是副本列表的子集，当前仍处于活动状态并追随领导者。)

[hadoop@hadoop000 tmp]$ kafka-topics.sh --describe --zookeeper hadoop000:2181 --topic my-replicated-topic
Topic:my-replicated-topic   PartitionCount:1    ReplicationFactor:3 Configs:Topic: my-replicated-topic  Partition: 0    Leader: 3   Replicas: 3,1,2 Isr: 1,2,3

2. 查看三个broker的配置

[hadoop@hadoop000 tmp]$ jps -m
3761 ConsoleProducer --broker-list hadoop000:9093,hadoop000:9094,hadoop000:9095 --topic my-replicated-topic
4178 Jps -m
3717 ConsoleConsumer --zookeeper hadoop000:2181 --from-beginning --topic my-replicated-topic
3637 ConsoleProducer --broker-list hadoop000:9092 --topic my-replicated-topic
3175 QuorumPeerMain /home/hadoop/app/zookeeper-3.4.5-cdh5.7.0/bin/../conf/zoo.cfg
3788 ConsoleConsumer --zookeeper hadoop000:2181 --topic my-replicated-topic
3310 Kafka /home/hadoop/app/kafka_2.11-0.9.0.0/config/server-2.properties
3230 Kafka /home/hadoop/app/kafka_2.11-0.9.0.0/config/server-1.properties
3406 Kafka /home/hadoop/app/kafka_2.11-0.9.0.0/config/server-3.properties

3. 杀死broker2模拟容错

[hadoop@hadoop000 tmp]$ kill -9 3310#领导权已切换到关注者之一，并且节点2不再位于同步副本集中：
[hadoop@hadoop000 tmp]$ jps -m
4208 Jps -m
3761 ConsoleProducer --broker-list hadoop000:9093,hadoop000:9094,hadoop000:9095 --topic my-replicated-topic
3717 ConsoleConsumer --zookeeper hadoop000:2181 --from-beginning --topic my-replicated-topic
3637 ConsoleProducer --broker-list hadoop000:9092 --topic my-replicated-topic
3175 QuorumPeerMain /home/hadoop/app/zookeeper-3.4.5-cdh5.7.0/bin/../conf/zoo.cfg
3788 ConsoleConsumer --zookeeper hadoop000:2181 --topic my-replicated-topic
3230 Kafka /home/hadoop/app/kafka_2.11-0.9.0.0/config/server-1.properties
3406 Kafka /home/hadoop/app/kafka_2.11-0.9.0.0/config/server-3.properties[hadoop@hadoop000 tmp]$ kafka-topics.sh --describe --zookeeper hadoop000:2181 --topic my-replicated-topic
Topic:my-replicated-topic   PartitionCount:1    ReplicationFactor:3 Configs:Topic: my-replicated-topic  Partition: 0    Leader: 3   Replicas: 3,1,2 Isr: 1,3

4. 但是，即使最初进行写操作的领导者已经下线，消息仍然可以使用

[hadoop@hadoop000 ~]$ kafka-console-consumer.sh --zookeeper hadoop000:2181 --from-beginning --topic my-replicated-topic
hello[hadoop@hadoop000 ~]$ kafka-console-producer.sh --broker-list hadoop000:9093,hadoop000:9094,hadoop000:9095 --topic my-replicated-topic
hello

至此说明 Kafka的容错性是完全有保障的。

Kafka容错性测试相关推荐

kafka压力测试说明
1 整体环境说明 1.1 硬件环境 1. 磁盘:SATA磁盘2块,磁盘阵列为RAID1 2. CPU****:2个4核CPU.具体参数:Intel(R) Xeon(R) CPU E5405 @ 2.0 ...
软件测试基础按照测试对象划分界面测试（UI测试.响应式页面可靠性测试容错性测试文档测试平台测试易用性测试等
软件测试进阶 1.APP 的测试 2. 按照测试对象划分 2.1界面测试(UI测试) 3.响应式页面 4.可靠性测试 5.容错性测试 6.文档测试 7.平台测试: 7.1 PC: 7.2.手机端: 8 ...
Kafka吞吐量测试案例
Kafka吞吐量测试案例作者:尹正杰版权声明:原创作品,谢绝转载!否则将追究法律责任. 领英公司参考连接:https://www.slideshare.net/JiangjieQin/produc ...
4. Flume和Kafka连通测试
1. Kafka 安装与配置 1.1 下载Kafka 在官网下载kafka,kafka_2.11-2.1.1.tgz. 1.2 解压解压至指定目录.tar -zxvf -C 你的目录 1.3 启动k ...
kafka吞吐量测试
参考文章: https://cloud.tencent.com/developer/article/1587057 kafka吞吐量测试 (1) 测试kafka生产者的吞吐量 [root@hadoop ...
Kafka Rebalance测试
Kafka Rebalance测试关于kafka的Rebalance机制,其实就是规定同一个consumer group下所有的consumer如何协调工作的,分配订阅Topic分区的.Rebala ...
Kafka 教程（二）集群搭建和容错性测试
2019独角兽企业重金招聘Python工程师标准>>> 在之前我们已经安装过kafka,我们直接进行单机多broker搭建.kafka安装请参考:kafka 教程(一) 第一个实例 ...
Kafka压力测试(写入MQ消息压测和消费MQ消息压测）
1.测试目的本次性能测试在正式环境下单台服务器上Kafka处理MQ消息能力进行压力测试.测试包括对Kafka写入MQ消息和消费MQ消息进行压力测试,根据10w.100w和1000w级别的消息处理结果 ...
java客户端作为kafka消费者测试
[README] 本文主要对 java客户端作为kafka 消费者进行测试, 生产者由 kafka客户端扮演: [1]普通消费者设置消费者组: 重置消费者的offset, 即每次都从最头开始消费(默 ...
java客户端作为kafka生产者测试
[README] 1.本文主要对 java客户端作为kafka 生产者进行测试, 消费者由 centos的kafka命令行线程扮演: 2.消息发送: kafka的生产者采用异步发送消息的方式,在消息发 ...

Kafka容错性测试

Kafka容错性测试相关推荐

最新文章

热门文章