gpt4 book ai didi

java - 如果 kafka 消费者指定的偏移量不存在于 Broker 中,会发生什么情况?

转载 作者:行者123 更新时间:2023-12-03 20:14:49 25 4
gpt4 key购买 nike

我是卡夫卡的新手。我想了解 kafka 消费者在其指定的偏移量不存在时的行为。可能由于保留策略或消费者指定了无效的偏移值,给定偏移量处的消息被删除。

最佳答案

您的消费者将使用您的 auto.offset.reset 设置将其偏移量重置为有效位置。如果未指定重置选项,则 Broker 将抛出 InvalidOffsetException .

关于java - 如果 kafka 消费者指定的偏移量不存在于 Broker 中,会发生什么情况?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58956265/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com