我有一个由3个独立的物理节点组成的kafka集群,每个节点都承载 1 zk
以及 1 broker
每个。我们使用的是Kafka0.10.1.1。主题是在zk集合上创建的,代理程序连接到zk集合。我的 Producer
以及 Consumer
是一个spring boot应用程序(版本1.5.13)。我们有几个关于单分区的主题(即- Partition 0
), min.insync.replicas=2
以及 replication_factor=3
. 到目前为止,当我们检查通过 --describe
主题中,我们发现所有副本都是同步的。reg consumer groups,我们已经看到,只有当consumer groups处于活动状态时,它才会通过cli和kafka manager显示。直到这里一切都好。
我们增加了个人 zk:2181
作为单个集群 Kafka-manager
用于监控。我们看到即使 consumer groups
它们不是活动的,它们以不同的滞后值出现在某些簇中(即在Zookeeper上)。某些主题的滞后显示所在的节点甚至不是同一主题的前导节点。当我们使用cli进行交叉检查时,消费者组甚至不会出现,除了 KMOffsetCache-<<instance-name>>
. kafka-consumer-groups.sh --bootstrap-server ...
似乎zk(s)或consumer(u)偏移没有正确同步。我想知道为什么?又该如何矫正?
暂无答案!
目前还没有任何答案,快来回答吧!