马老师jvm调优之深入jvm底层原理
@Bean
public CommonErrorHandler kafkaErrorHandler(KafkaTemplate<String, String> kafkaTemplate) {
ConsumerRecordRecoverer recoverer = new DeadLetterPublishingRecoverer(kafkaTemplate);
// 间隔3秒，重试2次，共三次
BackOff backOff = new FixedBackOff(3000, 2);
return new DefaultErrorHandler(recoverer, backOff);
}
