【发布时间】:2023-03-31 19:40:01
【问题描述】:
如果订阅kafka主题的程序被终止并重新执行,最新的偏移量似乎没有被应用。 再次输出之前调用的数据。
ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG = false;
ConsumerConfig.MAX_POLL_RECORDS_CONFIG = 1;
ConsumerConfig.AUTO_OFFSET_RESET_CONFIG = latest;
【问题讨论】:
标签: apache-kafka