Dear Kafka fans,
I have a concern of testing Kafka fault tolerance. Or may I did not configure
it right.
I have two kafka servers and one zookeeper, which are running on three
different AWS EC2 instances. I created a topic with one partition and two
replica. First, the two kafka servers were running and everything was perfect.
After I shut down the leader for my topic, the producer and the consumer just
stopped working. Why did Kafka system stop working? I did not see any fault
tolerance here. However, when I restarted the leader (I just shut down ), the
producer and consumer started to work again. Here is my topic description:
Topic:fast-messages PartitionCount:1 ReplicationFactor:2 Configs:
Topic: fast-messages Partition: 0 Leader: 1 Replicas: 1,0
Isr: 1,0
Any comments or suggestions are highly appreciated!
Thanks!
Chao