【问题标题】:kafka consumer topic offset not able to apply latest issuekafka消费者主题偏移无法应用最新一期
【发布时间】: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


    【解决方案1】:

    重置配置仅适用于消费者组尚不存在的情况。如果您总是想要最新消息,则需要致电seekToEnd()

    【讨论】:

    • 感谢您强制更新偏移量。
    • 如果这回答了您的问题,请随时使用帖子旁边的复选标记接受答案
    猜你喜欢
    • 2019-06-10
    • 2021-08-09
    • 2019-05-01
    • 2018-10-27
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2017-05-12
    • 1970-01-01
    相关资源
    最近更新 更多