接口的Kafka JSON反序列化程序

Question

我遇到了类似的问题：Kafka反序列化我的Kafka生产者中的嵌套泛型类型，我发送的对象如下所示：

public class ExternalTO implements Serializable
{
    private static final long serialVersionUID = 7949808917892350503L;
    private List<IExternalData> externalDatas;

    public ExternalTO()
    {}
}

其基石是:列表 ExternalDataS 。

此界面如下所示：

@JsonTypeInfo(use = JsonTypeInfo.Id.CLASS)
public interface IExternalData
{
    String getOne();
}

{
"externalDatas":
[{"@class":"com.api.external.to.ConcreteExternalData",
"one":false,
"two":false}]
}

添加字段@class是因为@JsonTypeInfo注释，我认为这足以让反序列化器“理解”在反序列化中使用什么类型的IExternalData。不幸的是,在Kafka的听众那边,我得到了一个例外：

无法构造com.api.external.to.iExternalData的实例（不存在像default construct这样的创建者）：抽象类型需要映射到具体类型、具有自定义反序列化程序或包含其他类型信息

Consumer看起来类似于：

@Service
public class Consumer
{
    private final ObjectMapper objectMapper;


    public Consumer(ObjectMapper objectMapper)
    {
        this.objectMapper = objectMapper;
    }


    @KafkaListener(topics = {"${kafka.topic}"})
    public void listen(ConsumerRecord<String, String> record)
    {
        objectMapper.readValue(record.value(), ExternalTO.class)
    }

Answer 1

在iExternalData的所有实现中，反序列化程序不知道应该将使用者记录数据反序列化到哪个实现。我们必须解决这种模棱两可的问题。我能够使用@JsonDeserialize注释解决这个问题。

@jsonDeserialize(as= .class

在清单声明之上