我正在嘗試使用 spring-kafka 處理毒丸場景。目前我正在使用以下方法處理這個問題，這里失敗的訊息被推送到一個名為<original-topic>.DLT.
@Bean
public SeekToCurrentErrorHandler errorHandler(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer) {
return new SeekToCurrentErrorHandler(deadLetterPublishingRecoverer);
}
@Bean
public DeadLetterPublishingRecoverer publisher(KafkaTemplate bytesTemplate) {
return new DeadLetterPublishingRecoverer(bytesTemplate);
}
因此<original-topic>.DLT，我不想將失敗的訊息推送到主題，而是想獲取它并將其直接推送到資料庫中。我試圖獲得失敗的訊息，但沒有成功。任何人都可以在這里幫忙。TIA。
uj5u.com熱心網友回復：
只需實作您自己的ConsumerRecordRecoverer并在錯誤處理程式中使用它而不是DeadLetterPublishingRecoverer.
/**
* A {@link BiConsumer} extension for recovering consumer records.
*
* @author Gary Russell
* @since 2.3
*
*/
@FunctionalInterface
public interface ConsumerRecordRecoverer extends BiConsumer<ConsumerRecord<?, ?>, Exception> {
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/gongcheng/360877.html