0

我需要使用 confluent_kafka python 包计算两个偏移量之间的消息数。我之前假设消息的数量将是偏移量之间的差异（即结束 - 开始），但显然 kafka 有时会将偏移量增加 >1，从而使上述不准确。

给定单个分区中的两个偏移量 offset_start 和 offset_end，我如何计算它们之间的消息数？

4

0 回答 0