Spring Kafka 模板根据不同情况发送重试

Question

我正在使用 Spring Kafka 的 KafkaTemplate 以异步方式发送消息并使用回调进行适当的错误处理。

此外，我已将 Kafka 生产者配置为具有最大重试次数 (MAX_INTEGER)。

然而，可能存在一些与 avro 序列化相关的错误，但对于那些重试无济于事。那么，如何在不重试的情况下避免这些错误，但对于我想重试的其他代理相关问题？

Answer 1

序列化异常会在消息发送前发生，所以retries 属性在这种情况下是无关紧要的；它仅在实际发送消息时适用。