即使 Kafka 连接断开，应用程序也应该继续运行

Question

我正在向外部团队发布消息，该团队使用 Kafka 的消息并向我们返回响应。每当我们的应用程序正在运行并尝试向 Kafka 发送发布消息时，如果 Kafka 连接丢失或关闭，那么我们的应用程序就会抛出异常。 我希望即使 Kafka 连接中断，我的应用程序也不应该中断。 Kafka 主题由其他团队处理，我无法更改他们的代码。 有什么办法可以让我的应用程序通过绕过 Kafka 步骤继续运行而不会产生任何影响？

Answer 1

您可以增加生产者配置retries并将其设置为较大的数字，例如Integer.MAX_VALUE。