confluent-kafka-sparkstreaming

Error deserializing key/value for partition historysignal-1 at offset 0. If needed, please seek past the record to continue consumption, Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 1 Caused by: java.lang.ArrayIndexOutOfBoundsException: 21

  val kafkaParam = Map[String,Object](
        "bootstrap.servers" -> "10.20.201.99:9092",
        "key.deserializer" -> classOf[StringDeserializer],
        "value.deserializer" -> classOf[KafkaAvroDeserializer],
        "group.id" -> "xgtestlocal",
        "auto.offset.reset" -> "latest",
        //      "max,poll,records" -> "10000",
        "enable.auto.commit" -> (false: java.lang.Boolean),
        "schema.registry.url" -> "https://10.20.201.99:8081"
      )

org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition historysignal-1 at offset 0. If needed, please seek past the record to continue consumption.Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 1Caused by: java.lang.ArrayIndexOutOfBoundsException: 21
      at org.apache.avro.io.parsing.Symbol$Alternative.getSymbol(Symbol.java:424)
      at org.apache.avro.io.ResolvingDecoder.doAction(ResolvingDecoder.java:290)
      at org.apache.avro.io.parsing.Parser.advance(Parser.java:88)
      at org.apache.avro.io.ResolvingDecoder.readIndex(ResolvingDecoder.java:267)
      at

预览