更改 KafkaBackOffException 日誌級別
當重試主題中的訊息尚未到消費時間時,會丟擲 KafkaBackOffException
。此類異常預設以 DEBUG
級別記錄日誌,但您可以透過在 @Configuration
類中設定 ListenerContainerFactoryConfigurer
的錯誤處理程式定製器來更改此行為。
例如,要將日誌級別更改為 WARN,您可以新增
@Override
protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
customizersConfigurer.customizeErrorHandler(defaultErrorHandler ->
defaultErrorHandler.setLogLevel(KafkaException.Level.WARN))
}