Confluent kafka REST 代理返回空的已提交偏移量



我正在使用Confluent REST代理v.3.2.0,最近我从auto.commit.enable=true切换到false,所以现在我正在积极获取和提交偏移量。目标是在每次创建使用者时依赖承诺的偏移量,而不是消耗的偏移量。这背后的原因是,在微服务在使用消息后崩溃但在处理消息的过程中,我们不要跳过处理消息,这一点非常重要。偏移量在使用 POST ==>/consumer/(字符串:group_name(/实例/(字符串:实例(/偏移量成功处理后会更新。对我们来说,重新处理消息不是问题,我们得到相同的结果,因此可以容忍倒带。

问题是我们在调用的响应中得到了空偏移量:GET ==>/consumer/(字符串:group_name(/实例/(字符串:实例(/偏移量

为什么我会在响应中获得空偏移量,我该怎么做才能以编程方式解决此问题?我尝试调用 POST ==>/position/begin,但这没有帮助,因为下次尝试时我仍然会得到空偏移量。

使用默认设置时,偏移量将在 24 小时后过期,因此如果您想在更长时间不活动的情况下保持仓位,则需要在代理server.properties配置文件中增加offsets.retention.minutes参数。

否则,如果偏移量过期,则使用者将根据 kafka-rest.properties 文件中配置的重置策略参数auto.offset.reset的配置重置策略参数重置为主题的开头或结尾。

最新更新