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

Question

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

标签： apache-kafkakafka-consumer-apikafka-producer-api

Answer 1

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