更改 KafkaBackOffException 日誌級別

當重試主題中的訊息尚未到消費時間時,會丟擲 KafkaBackOffException。此類異常預設以 DEBUG 級別記錄日誌,但您可以透過在 @Configuration 類中設定 ListenerContainerFactoryConfigurer 的錯誤處理程式定製器來更改此行為。

例如,要將日誌級別更改為 WARN,您可以新增

@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
    customizersConfigurer.customizeErrorHandler(defaultErrorHandler ->
            defaultErrorHandler.setLogLevel(KafkaException.Level.WARN))
}