春云流 - 反序列化失败 - 解析类名失败。未找到类

Question

应用程序A写入用户对象（json）下面的Kafka主题：

public class UserEvent {
   private UUID id; 
   private Object payload; // contains User fields name etc.
}

应用程序 B 正在尝试使用此用户对象（用户.java驻留在应用程序 B 项目中）与以下 application.yml（多个绑定器）：

    binders:
    azureEventHub:
        type: kafka
        environment:
            spring:
                kafka:
                    bootstrap-servers: servicebus.windows.net:9093
                    consumer:
                        key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
                        value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
                        properties:
                            spring.deserializer.key.delegate.class: org.apache.kafka.common.serialization.StringDeserializer
                            spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer
                            spring.json.trusted.packages: com.*
                            spring.json.value.default.type: com.applicationb.User

下面是我的Spring Cloud Stream处理器类的外观:

  @Bean 
  public Function<Message<User>, String> userProcessor()  
  {..  }

但是，它没有将Message有效负载转换为“用户”类，而是不断抛出错误，未找到
父类“User事件”。

org.springframework.kafka.listener.ListenerExecutionFailedException: 
Listener failed; nested exception is org.springframework.kafka.support.serializer.DeserializationException: 
failed to deserialize; nested exception is org.springframework.messaging.converter.MessageConversionException: 
failed to resolve class name. Class not found [com.abcd.UserEvent]; 
nested exception is java.lang.ClassNotFoundException: com.abcd.UserEvent

有什么想法吗？

Answer 1

反序列化程序将在返回到默认值（User）之前使用标头中的类型信息。

同时设置spring.json.use.type。headers＜/code＞到＜code＞false＜/code>。