org.apache.kafka.connect.errors.DataException: Failed to deserialize data to Avro:

GitHub | amitmalagi | 8 months ago
  1. 0

    HDFS connector issue

    GitHub | 8 months ago | amitmalagi
    org.apache.kafka.connect.errors.DataException: Failed to deserialize data to Avro:
  2. Speed up your debug routine!

    Automated exception search integrated into your IDE

  3. 0

    Avro decoding gives java.io.EOFException

    Stack Overflow | 8 months ago | Ratha
    java.io.EOFException
  4. 0

    Avro schema doesn't honor backward compatibilty

    Stack Overflow | 11 months ago | Raghvendra Singh
    java.io.EOFException: null
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.io.EOFException

    No message provided

    at org.apache.avro.io.BinaryDecoder$ByteArrayByteSource.readRaw()
  2. Apache Avro
    GenericDatumReader.read
    1. org.apache.avro.io.BinaryDecoder$ByteArrayByteSource.readRaw(BinaryDecoder.java:944)
    2. org.apache.avro.io.BinaryDecoder.doReadBytes(BinaryDecoder.java:349)
    3. org.apache.avro.io.BinaryDecoder.readString(BinaryDecoder.java:263)
    4. org.apache.avro.io.ResolvingDecoder.readString(ResolvingDecoder.java:201)
    5. org.apache.avro.generic.GenericDatumReader.readString(GenericDatumReader.java:363)
    6. org.apache.avro.generic.GenericDatumReader.readString(GenericDatumReader.java:355)
    7. org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:157)
    8. org.apache.avro.generic.GenericDatumReader.readField(GenericDatumReader.java:193)
    9. org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:183)
    10. org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:151)
    11. org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:142)
    11 frames
  3. io.confluent.kafka
    AbstractKafkaAvroDeserializer.deserializeWithSchemaAndVersion
    1. io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.deserialize(AbstractKafkaAvroDeserializer.java:130)
    2. io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.deserializeWithSchemaAndVersion(AbstractKafkaAvroDeserializer.java:191)
    2 frames
  4. io.confluent.connect
    AvroConverter.toConnectData
    1. io.confluent.connect.avro.AvroConverter$Deserializer.deserialize(AvroConverter.java:130)
    2. io.confluent.connect.avro.AvroConverter.toConnectData(AvroConverter.java:99)
    2 frames
  5. org.apache.kafka
    WorkerSinkTask.poll
    1. org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:266)
    2. org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:175)
    2 frames