gpt4 book ai didi

java - Kafka - 偏移量和 logSize

转载 作者:行者123 更新时间:2023-11-30 03:02:42 26 4
gpt4 key购买 nike

在查找 Kafka 日志的 ddetails 时,我看到以下详细信息。这是否意味着总共有 17905513 条消息,其中 17905510 条已被读取,3 条待读取?

Offset      logSize     Lag 
17905510 17905513 3

最佳答案

差不多了。 Kafka 会不时保存偏移量(取决于设置)。它不会在读取或处理每条消息后保存偏移量。因此,这可能意味着消费者还没有读取最后三个消息,但也可能意味着它已经读取了所有待处理的消息,但 ZK 中的偏移量尚未更新。

关于java - Kafka - 偏移量和 logSize,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35559696/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com