Kafka - 知道消费者是否是最新的
Kafka - Know if Consumer is up to date
我将 Kafka 0.9.0 与本机 Java 消费者客户端一起使用。
如果我有 1 个主题和 1 个分区
如果我这样做，有人可以告诉我：
seekToEnd（我的主题）；
投票（x）；
我只会得到最后一条记录，所以我会知道我在最后一个位置？
是的，你只会得到最后的（最新的）记录，因为seekToEnd()方法“延迟计算”所以直到[=11才计算结束=] 被调用。当然，到 poll() 方法 returns 时，可以添加更多消息；所以不能保证你的偏移量是 "in the last position" 除了在方法执行的那一刻。
我将 Kafka 0.9.0 与本机 Java 消费者客户端一起使用。 如果我有 1 个主题和 1 个分区 如果我这样做，有人可以告诉我： seekToEnd（我的主题）； 投票（x）；
我只会得到最后一条记录，所以我会知道我在最后一个位置？
是的，你只会得到最后的（最新的）记录，因为seekToEnd()方法“延迟计算”所以直到[=11才计算结束=] 被调用。当然，到 poll() 方法 returns 时，可以添加更多消息；所以不能保证你的偏移量是 "in the last position" 除了在方法执行的那一刻。