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

问题描述

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

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

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）