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 上下文中声明您可以记录或想要的任何内容。