Kafka抵消了不同步

Question

我有一个带有1个zookeeper节点的3节点kafka集群.

查询每个代理的偏移量给了我不同的分区偏移量(分区2).Broker 0卡在Partition 2的特定偏移值上.我对此有几个问题:

1. 这种滞后会影响生产者吗？
2. 消费者可以查询不是该分区的领导者的代理吗？
3. 我在这个分区上丢失了一个ISR; 如何将群集恢复到正常状态？我可以监控哪些指标来检查节点是否正在赶上？

KAFKA版本:0.8.2.1

    /bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic AdServe  --broker-list broker0:9092 --time -1
    AdServe:0:25186452
    AdServe:1:26748318
    AdServe:2:15659873

    ./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic AdServe  --broker-list broker1:9092 --time -1
    AdServe:0:25186652
    AdServe:1:26748318
    AdServe:2:19100186

    ./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic AdServe  --broker-list broker2:9092 --time -1
    AdServe:0:25187252
    AdServe:1:26748318
    AdServe:2:19103185


Topic status on zookeeper:

    Topic:AdServe   PartitionCount:3    ReplicationFactor:2 Configs:
        Topic: AdServe  Partition: 0    Leader: 1   Replicas: 1,0   Isr: 0,1
        Topic: AdServe  Partition: 1    Leader: 2   Replicas: 2,1   Isr: 2,1
        Topic: AdServe  Partition: 2    Leader: 2   Replicas: 0,2   Isr: 2

Answer 1

我发现重新启动该主题的主要经纪人整理了ISR.

本文对于理解Kafka复制以及如何监视主题是否同步非常有用

https://www.confluent.io/blog/hands-free-kafka-replication-a-lesson-in-operational-simplicity/