如何使用 apache kafka 消息进行分页
How to paginate with apache kafka messages
分页系统使用总记录完成并指定偏移量以开始分页。
如何从控制台获取kafka中的总记录和偏移量？
Kafka 不分页。主题是事件的顺序日志。
但是，您的消费者组有一个初始或存储的偏移量，并且在下一次轮询时，将读取该偏移量之后的下一个“页面”最多 max.poll.records。
如果要统计非压缩主题的记录数，可以使用GetOffsetShell工具查询首末偏移量，然后减去差值。对于紧凑的主题，这些数字之间存在差距，计算记录的唯一合理方法是消耗整个主题
分页系统使用总记录完成并指定偏移量以开始分页。
如何从控制台获取kafka中的总记录和偏移量？
Kafka 不分页。主题是事件的顺序日志。
但是，您的消费者组有一个初始或存储的偏移量，并且在下一次轮询时，将读取该偏移量之后的下一个“页面”最多 max.poll.records。
如果要统计非压缩主题的记录数，可以使用GetOffsetShell工具查询首末偏移量，然后减去差值。对于紧凑的主题，这些数字之间存在差距，计算记录的唯一合理方法是消耗整个主题