首页 文章

Kafka抵消了不同步

提问于
浏览 次
1

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

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

  • 这种滞后会影响 生产环境 者吗？

  • 消费者可以查询不是该分区的领导者的代理吗？

  • 我在这个分区上丢失了一个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
apache-zookeeper apache-kafka

1 回答

相关问题