我正在使用confluent rest proxy v.3.2.0,最近我从auto.commit.enable=true转换为false,所以现在我正在积极地获取和提交偏移量。目标是每次创建消费者时都依赖于提交的补偿,而不是消费的补偿。这背后的原因是,对于我们来说,当微服务在消费消息后崩溃,而在处理消息的过程中崩溃时,不要跳过处理消息是非常重要的。使用post==>/consumers/(string:group\u name)/instances/(string:instance)/offset成功处理偏移量后,将更新偏移量。对我们来说,重新处理消息不是一个问题,我们得到相同的结果,所以可以允许倒带。
问题是我们在call:get==>/consumers/(string:group\u name)/instances/(string:instance)/offset的响应中得到了空的偏移量
为什么我会得到空偏移量的响应,我可以做什么来修复这个编程?我试着打电话到post==>/positions/beging,但是没有用,因为我下次尝试时仍然得到空的偏移量。
1条答案
按热度按时间dtcbnfnu1#
在默认设置下,偏移量在24小时后过期,因此如果您想在较长时间内保持不活动状态,则需要增加偏移量
offsets.retention.minutes
代理中的参数server.properties
配置文件。否则,如果偏移过期,则使用者将根据重置策略参数的配置重置为主题的开头或结尾
auto.offset.reset
在kafka-rest.properties文件中配置。