0


模拟宕机后kafka的重新分区

直接停掉192.168.233.133:9092 (broker.id = 5)

查看topic 分区

  1. $ /data/kafka_2.13-3.0.0/bin/kafka-topics.sh --bootstrap-server 192.168.233.132:9092 --topic quickstart77-events --describe
  2. Topic: quickstart77-events TopicId: A7bNWYseSNqlGfs1XPhN9g PartitionCount: 6 ReplicationFactor: 2 Configs: segment.bytes=1073741824
  3. Topic: quickstart77-events Partition: 0 Leader: 4 Replicas: 5,4 Isr: 4
  4. Topic: quickstart77-events Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2
  5. Topic: quickstart77-events Partition: 2 Leader: 4 Replicas: 4,3 Isr: 4,3
  6. Topic: quickstart77-events Partition: 3 Leader: 2 Replicas: 2,0 Isr: 2,0
  7. Topic: quickstart77-events Partition: 4 Leader: 3 Replicas: 3,5 Isr: 3
  8. Topic: quickstart77-events Partition: 5 Leader: 0 Replicas: 0,1 Isr: 0,1

宕掉的broker已经不在leader和Isr中,Replicas依然还在

恢复192.168.233.133:9092 (broker.id = 5)

  1. $ /data/kafka_2.13-3.0.0/bin/kafka-topics.sh --bootstrap-server 192.168.233.132:9092 --topic quickstart77-events --describe
  2. Topic: quickstart77-events TopicId: A7bNWYseSNqlGfs1XPhN9g PartitionCount: 6 ReplicationFactor: 2 Configs: segment.bytes=1073741824
  3. Topic: quickstart77-events Partition: 0 Leader: 4 Replicas: 5,4 Isr: 4,5
  4. Topic: quickstart77-events Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2
  5. Topic: quickstart77-events Partition: 2 Leader: 4 Replicas: 4,3 Isr: 4,3
  6. Topic: quickstart77-events Partition: 3 Leader: 2 Replicas: 2,0 Isr: 2,0
  7. Topic: quickstart77-events Partition: 4 Leader: 3 Replicas: 3,5 Isr: 3,5
  8. Topic: quickstart77-events Partition: 5 Leader: 0 Replicas: 0,1 Isr: 0,1

Isr中已经恢复看到了,但是leader中还是没有

再过一段时间再观察

  1. $ /data/kafka_2.13-3.0.0/bin/kafka-topics.sh --bootstrap-server 192.168.233.132:9092 --topic quickstart77-events --describe
  2. Topic: quickstart77-events TopicId: A7bNWYseSNqlGfs1XPhN9g PartitionCount: 6 ReplicationFactor: 2 Configs: segment.bytes=1073741824
  3. Topic: quickstart77-events Partition: 0 Leader: 5 Replicas: 5,4 Isr: 4,5
  4. Topic: quickstart77-events Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2
  5. Topic: quickstart77-events Partition: 2 Leader: 4 Replicas: 4,3 Isr: 4,3
  6. Topic: quickstart77-events Partition: 3 Leader: 2 Replicas: 2,0 Isr: 2,0
  7. Topic: quickstart77-events Partition: 4 Leader: 3 Replicas: 3,5 Isr: 3,5
  8. Topic: quickstart77-events Partition: 5 Leader: 0 Replicas: 0,1 Isr: 0,1

leader也能自动恢复了

标签: kafka 分布式

本文转载自: https://blog.csdn.net/daelly/article/details/132100241
版权归原作者 daelly 所有, 如有侵权,请联系我们删除。

“模拟宕机后kafka的重新分区”的评论:

还没有评论