我正在使用 spring kafka 来实现具有默认属性的 kafka 侦听器。我注意到有一些失败，例如：代理不可用或消费消息后任何内部调用失败，它会停止消费消息，并且在提交之前消费的消息时我可以看到附加错误。
我们如何让我们的 kafka 消费者重新连接到组并开始消费消息，而无需在 kubernetes 中重新启动 pod？目前，当我们重新启动我们的 kubernetes pod 时，kafka 消费者开始收听来自上次提交的偏移量的消息。
我正在使用 spring kafka 来实现具有默认属性的 kafka 侦听器。我注意到有一些失败，例如：代理不可用或消费消息后任何内部调用失败，它会停止消费消息，并且在提交之前消费的消息时我可以看到附加错误。
我们如何让我们的 kafka 消费者重新连接到组并开始消费消息，而无需在 kubernetes 中重新启动 pod？目前，当我们重新启动我们的 kubernetes pod 时，kafka 消费者开始收听来自上次提交的偏移量的消息。