【问题标题】:Kafka - Offset and logSizeKafka - 偏移量和 logSize
【发布时间】:2016-02-23 03:09:27
【问题描述】:

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

Offset      logSize     Lag 
17905510    17905513    3

【问题讨论】:

    标签: java apache-kafka apache-zookeeper


    【解决方案1】:

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

    【讨论】:

    • 谢谢卢卡斯!那么 offset 和 logsize 下面的数字是指消息数吗?
    • 是的,你是对的,评论必须至少 15 个字符长 :)
    • 感谢 Lukas,长度绝对应该超过 15 个字符 :--)
    猜你喜欢
    • 1970-01-01
    • 2019-11-25
    • 2014-08-08
    • 2018-05-30
    • 2021-02-22
    • 1970-01-01
    • 2021-04-10
    • 2019-05-01
    相关资源
    最近更新 更多