kafka使用者(通过新的使用者api创建)的偏移和滞后设置为未知

goqiplq2 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(325)

我经常看到这样一个问题，Kafka消费者得到当前抵消和滞后设置为未知
早期的消费者有抵消和滞后

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER  
G.AB_KAFF, T.AB_KAFF, 0, 3, 6, 3, consumer-2
G.AB_KAFF, T.AB_KAFF, 1, 8, 11, 3, consumer-2

当我在几天后再次订阅这个消费者时，它的偏移和延迟被设置为未知

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER  
G.AB_KAFF, T.AB_KAFF, 0, unknown, 7, unknown, consumer-2
G.AB_KAFF, T.AB_KAFF, 1, unknown, 11, unknown, consumer-2

Kafka是不是因为我取消了整个消费群体的订阅而取消了之前对该消费者的补偿？

apache-kafka kafka-consumer-api producer-consumer

来源：https://stackoverflow.com/questions/38092337/offset-and-lag-for-kafka-consumer-created-via-new-consumer-api-are-set-to-unkn