用avro模式中的java.util.list读取来自kafka的消息

goqiplq2  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(364)

我正在尝试使用具有以下属性的消费者来读取来自kafka的消息

value.deserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer
key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
specific.avro.reader=true

模式是

{
      "type" : "array",
      "items" : {
          "type" : "record",
          "name" : "MyDto",
          "namespace" : "test.dto",
          "fields" : [ {
            "default" : null,
            "name" : "version",
            "type" : ["null","string"]
          }, {
            "default" : null,
            "name" : "testName",
            "type" : ["null","string"]
          }, {
            "name" : "keys",
            "type" : {"type": "array", "items": "string"},
            "java-class" : "java.util.List"
          }]
        },
      "java-class" : "java.util.List"
}

使用此架构成功地将对象写入Kafka。但是在反序列化的时候我遇到了一个例外 java.lang.NoSuchMethodException: java.util.List.<init>() 是否可以使用java.util.list类?我正在使用confluent 3.1.2

b09cbbtk

b09cbbtk1#

List 是一个接口,它没有构造函数或具体实现。您的生产者可能正在使用arraylist,读者模式和使用者也应该使用
请确保使用 "java-class" : "java.util.ArrayList"

相关问题