我在查看Kafka日志的详细信息时看到了以下细节。这是否意味着总共有17905513条消息，其中17905510条已经被读取，3条等待读取？
Offset logSize Lag 17905510 17905513 3
jdgnovmf1#
几乎。Kafka会不时地保存偏移量（这取决于设置）。它不会在读取或处理每条消息后保存偏移量。因此，这可能意味着使用者尚未读取最后三条消息，但也可能意味着它已读取所有挂起的消息，但zk中的偏移量尚未更新。
1条答案
按热度按时间jdgnovmf1#
几乎。Kafka会不时地保存偏移量（这取决于设置）。它不会在读取或处理每条消息后保存偏移量。因此，这可能意味着使用者尚未读取最后三条消息，但也可能意味着它已读取所有挂起的消息，但zk中的偏移量尚未更新。