java - Kafka - 忽略获取的记录

Question

我的 Kafka 消费者正在读取来自名为 testdata 的 Kafka 主题的消息。消费者是 Apache Flink 源连接器。

当我向主题发送新消息时，消费者不会获取该消息。在调试日志中我可以看到以下消息:

Ignoring fetched records for testdata at offset 0 since the current position is 1

看来我的消费者总是有错误的偏移量？我可以做什么来获取该主题的消息？

更新:

我尝试了很多带有偏移设置的配置。我还清除了 Kafka 和 Zookeeper 的所有带有偏移量信息的 tmp 文件。但一切都没有改变。当前位置始终比偏移量前面一个数字。

调试日志行到底意味着什么？

Ignoring fetched records for testdata at offset 141 since the current position is 142

Answer 1

请设置enable.auto.commit=false