Spring Boot 2启用MessageHistory时无法发送kafka消息

Question

org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is java.lang.IllegalArgumentException: Incorrect type specified for header 'history'. Expected [class org.springframework.integration.history.MessageHistory] but actual type is [class org.springframework.kafka.support.DefaultKafkaHeaderMapper$NonTrustedHeaderType]. 

通过深入研究代码，在转换messagehistory标头https://github.com/spring-projects/spring-kafka/blob/14157742d7fa51ce8a22dfbdcdccc2e3c5b43c1c6f/spring-kafka/src/main/java/org/springframework/kafka/support/defaultkafkaheadermapper.java#l253-l275时，defaultkafkaheadermapper中引发

>

MessageHistory是否应该在发送前写入消息？

如果1）的答案是肯定的，那么将messagehistory设置为受信任包的正确方法是什么？

如果1）为否，那么在阻止将历史记录写入标头时，可能做了哪些错误的操作？

提前感谢！




Answer 1

您可以将org.springframework.integration.history包添加到白名单以还原以前的行为，方法是:defaultkafkaheadermapper.addTrustedPackages():

/**
 * Add packages to the trusted packages list (default {@code java.util, java.lang}) used
 * when constructing objects from JSON.
 * If any of the supplied packages is {@code "*"}, all packages are trusted.
 * If a class for a non-trusted package is encountered, the header is returned to the
 * application with value of type {@link NonTrustedHeaderType}.
 * @param packagesToTrust the packages to trust.
 */
public void addTrustedPackages(String... packagesToTrust) {

https://docs.spring.io/spring-kafka/docs/current/reference/html/#headers

或者您可以从映射中完全排除这样的标头。