You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by wuchang <58...@qq.com> on 2017/05/16 06:24:20 UTC
Why cannot kakfka copy data to a new replica automatically when one
of replica is down?
I have a kafka clusters with 3 brokers. 192.168.80.82,192.168.80.146 and 192.168.80.110
This is the topic description named DruidAppColdStartMsg:
[appuser@hz-192-168-80-146 kafka]$ bin/kafka-topics.sh --describe --topic DruidAppColdStartMsg --zookeeper 10.120.241.50:2181
Topic:DruidAppColdStartMsg PartitionCount:2 ReplicationFactor:2 Configs:
Topic: DruidAppColdStartMsg Partition: 0 Leader: 82 Replicas: 82,146 Isr: 82,146
Topic: DruidAppColdStartMsg Partition: 1 Leader: 110 Replicas: 110,82 Isr: 110,82
Obviously , the replication-factor of this topic is 2 , everything is ok.
Then , my 192.168.80.146 broker is down for some reason.
[appuser@hz-192-168-80-146 kafka]$ bin/kafka-topics.sh --describe --topic DruidAppColdStartMsg --zookeeper 10.120.241.50:2181
Topic:DruidAppColdStartMsg PartitionCount:2 ReplicationFactor:2 Configs:
Topic: DruidAppColdStartMsg Partition: 0 Leader: 82 Replicas: 82,146 Isr: 82
Topic: DruidAppColdStartMsg Partition: 1 Leader: 110 Replicas: 110,82 Isr: 110,82
From the Isr, the 146 is missing.I cannot produce message by kafka-console-producer to this topic unless I restart the 192.168.80.146 broker.
My question is , why kaka doesn’t make the active broker 192.168.80.110 to replace 192.168.80.146 as a new Isr for DruidAppColdStartMsg-0 ?
Is any configuration missing?
Thank you very much.