如何用DefaultErrorHandler（sping-kafka）替换弃用的SeekToFlutErrorHandler？

Question

我试图找到一种方法来使用新的DefaultErrorHandler而不是弃用的SeekToFlutErrorHandler在sping-kafka 2.8.1，以覆盖重试默认行为的错误情况下。我想“停止”重试过程，所以如果发生错误，不应该重试。

现在，在一个配置类中，我有了如下bean，它可以按预期工作：

@Bean
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setErrorHandler(new **SeekToCurrentErrorHandler(new FixedBackOff(0L, 1L)**));
    factory.setConsumerFactory(requestConsumerFactory());
    factory.setReplyTemplate(kafkaTemplate());
    return factory;
}

由于在这个Spring的kafka版本中，STCEH是弃用的，我试图在同一个配置类中html" target="_blank">执行以下操作：

@Bean
public DefaultErrorHandler eh() {
    return new DefaultErrorHandler(new FixedBackOff(0, 1));
}

但它似乎不起作用。如果出现错误，重试次数是默认的，正如我在日志中看到的：

[org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1]错误DefaultErrorHandler-Backoff FixedBackOff{interval=0，currentAttempts=10，maxAttempts=9}已为topicX耗尽

如何使用DefaultErrorHandler来实现所需的行为？还是我应该用别的？

提前谢谢！

Answer 1

factory.set通用错误处理程序（新的默认......）

CommonErrorHandlerbean的引导自动配置需要引导2.6。

https://github.com/spring-projects/spring-boot/commit/c3583a4b06cff3f53b3322cd79f2b64d17211d0e

Answer 2

>

factory.setErrorHandler（new SeekToFlutErrorHandler（new FixedBackoff（0L，1L））；实际上，它将重试最多1次传递（2次传递尝试）。（https://docs.spring.io/spring-kafka/docs/2.7.8/reference/html/#seek-to-current）

默认重试次数为**9（（（FixedBackoff（0L，9L））而不是1（https://docs.spring.io/spring-kafka/docs/2.8.1/reference/html/#default-eh）

您应该尝试setCommonErrorHandler而不是像factory那样的setErrorHandler。setCommonErrorHandler（新的DefaultErrorHandler（新的FixedBackOff（0L，0L））