馬老師jvm調(diào)優(yōu)之深入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);
?}
標(biāo)簽：
