微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Kafka使用者退出活动群组,无法再使用蚂蚁讯息

如何解决Kafka使用者退出活动群组,无法再使用蚂蚁讯息

我正在使用spring kafka来实现具有属性的kafka侦听器。我注意到存在一些故障,例如:代理不可用或使用消息后出现任何内部呼叫失败,它将停止使用消息,并且在提交先前使用的消息时可以看到附加的错误

我们如何让我们的kafka用户重新连接到组并开始使用消息,而无需在kubernetes中重启pod? 目前,当我们重新启动kubernetes pod时,kafka使用者开始侦听来自最后提交的偏移量的消息。

screenshot showing error message

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。