Springboot облако потока Kafka Binder, не регистрировать всю полезную нагрузку (failMessage = GenericMessage)

Question

В случае сбоя потребителя после повторных попыток, я вижу, что вся полезная нагрузка регистрируется. failedMessage=GenericMessage [payload= Есть ли простой способ замаскировать или скрыть это?

Answer 1

Вы должны объявить свой собственный errorChannel боб. Это действительно может быть тот же 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 контексте.