在kafka消费中获得'Shutting down ExecutorService'（org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler）

Question

我有时会在关闭 ExecutorService 时出错，然后 Consumer 停止。 Kafka事件再次处理，但出现重复，因为该事件已经处理到存储数据。我已经用幂等性修复了重复。但是有没有办法防止这种关闭？ ExponentialBackOffPolicy 的属性：

backOffPolicy.setMaxInterval(60000);
backOffPolicy.setMultiplier(2.0);
backOffPolicy.setInitialInterval(1000);
simpleRetryPolicy.setMaxAttempts(60);

Answer 1

是因为你重试间隔大，消费线程阻塞；由于错误处理程序支持后退和异常分类，因此不推荐使用侦听器适配器中的重试。错误处理程序还可以在容器停止时退出重试。

您使用适当配置的 DefaultErrorHandler（2.8 及更高版本）或早期版本的 SeekToCurrentErrorHandler（OSS 用户不再支持 2.7.10 之前的版本）。