Springboot cloud stream kafka binder,不记录整个有效负载(failedMessage=GenericMessage)
Springboot cloud stream kafka binder, Not to log the whole payload (failedMessage=GenericMessage)
在重试后消费者失败的情况下,我看到整个负载都被记录了。
failedMessage=GenericMessage [payload=
有没有简单的方法来掩盖或隐藏它?
您需要声明自己的 errorChannel
bean。它确实可以是相同的 PublishSubscribeChannel
并声明您自己的 LoggingHandler
作为该频道的订阅者。它的:
/**
* Set a SpEL expression string to use.
* @param expressionString the SpEL expression string to use.
* @since 4.3
* @see #setLogExpression(Expression)
*/
public void setLogExpressionString(String expressionString) {
可用于在传入的 Message
上下文中声明您可以记录或想要的任何内容。
在重试后消费者失败的情况下,我看到整个负载都被记录了。
failedMessage=GenericMessage [payload=
有没有简单的方法来掩盖或隐藏它?
您需要声明自己的 errorChannel
bean。它确实可以是相同的 PublishSubscribeChannel
并声明您自己的 LoggingHandler
作为该频道的订阅者。它的:
/**
* Set a SpEL expression string to use.
* @param expressionString the SpEL expression string to use.
* @since 4.3
* @see #setLogExpression(Expression)
*/
public void setLogExpressionString(String expressionString) {
可用于在传入的 Message
上下文中声明您可以记录或想要的任何内容。