查找Kafka日志的详细信息时，我会看到以下详细信息。这是否意味着总共有17905513条消息，其中已经读取了17905510条消息，还有3条待读。
Offset logSize Lag
17905510 17905513 3
几乎。Kafka会不时保存偏移量（取决于设置）。在读取或处理每条消息后，它不会保存偏移量。因此，这可能意味着使用者尚未读取最后三个消息，但也可能意味着它已读取所有未决消息，但ZK中的偏移量尚未更新。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句