如何解决春季云流-如果生产者闲置一段时间,则延迟消息处理
我们有两个具有相同使用者ID的Spring Cloud Stream侦听器服务实例。如果生产者闲置一个小时以上,则消费者需要大约15分钟的时间来处理在特定的空闲时间之后发布的下一条消息。我们试图调整一些属性,例如max.poll.interval.ms,max.poll.records,request.timeout.ms,session.timeout.ms,但这无济于事。
我们从日志中观察到,在延迟15分钟后,使用者正在尝试提交,但由于CommitFailedException而失败(“偏移提交无法完成,因为使用者不是自动分区分配的活动组的一部分;它可能是该消费者被赶出了群组。”)。重新平衡之后,将立即处理消息。
请帮助我们确定在特定的空闲时间后延迟邮件处理的根本原因。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。