【发布时间】:2016-02-23 03:09:27
【问题描述】:
在查找 Kafka 日志的详细信息时,我看到了以下详细信息。这是否意味着总共有 17905513 条消息,其中 17905510 条已被读取,3 条等待读取?
Offset logSize Lag
17905510 17905513 3
【问题讨论】:
标签: java apache-kafka apache-zookeeper
在查找 Kafka 日志的详细信息时,我看到了以下详细信息。这是否意味着总共有 17905513 条消息,其中 17905510 条已被读取,3 条等待读取?
Offset logSize Lag
17905510 17905513 3
【问题讨论】:
标签: java apache-kafka apache-zookeeper
几乎。 Kafka 会不时保存偏移量(取决于设置)。在读取或处理每条消息后,它不会保存偏移量。因此,这可能意味着消费者尚未读取最后三个消息,但也可能意味着它已读取所有待处理消息但 ZK 中的偏移量尚未更新。
【讨论】: