org.apache.kafka.connect.errors.DataException: Did not find matching union field for data: PROD

GitHub | sanchitgrover | 4 months ago
  1. 0

    Did not find matching union field for data

    GitHub | 4 months ago | sanchitgrover
    org.apache.kafka.connect.errors.DataException: Did not find matching union field for data: PROD
  2. 0

    Error while writing to HDFS using Kafka HDFS Connect

    Stack Overflow | 4 months ago | Sanchit
    org.apache.kafka.connect.errors.DataException: Did not find matching union field for data: PROD
  3. 0

    Exception while consuming bottledwater messages from Sink connector

    Google Groups | 7 months ago | Unmesh Joshi
    org.apache.kafka.connect.errors.DataException: Avro union types containing null are only supported as optional fields and should have exactly two entries.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    kafka connect fails to decode fixed properly

    GitHub | 6 months ago | jdehrlich
    org.apache.kafka.connect.errors.DataException: Invalid class for bytes type, expecting byte[] or ByteBuffer but found class org.apache.avro.generic.GenericData$Fixed
  6. 0

    Kafka connect is waiting long for connectors

    Google Groups | 5 months ago | Raju Divakaran
    org.apache.kafka.connect.errors.DataException: Failed to deserialize data to Avro:

    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. org.apache.kafka.connect.errors.DataException

      Did not find matching union field for data: PROD

      at io.confluent.connect.avro.AvroData.toConnectData()
    2. io.confluent.connect
      AvroConverter.toConnectData
      1. io.confluent.connect.avro.AvroData.toConnectData(AvroData.java:973)
      2. io.confluent.connect.avro.AvroData.toConnectData(AvroData.java:981)
      3. io.confluent.connect.avro.AvroData.toConnectData(AvroData.java:981)
      4. io.confluent.connect.avro.AvroData.toConnectData(AvroData.java:981)
      5. io.confluent.connect.avro.AvroData.toConnectData(AvroData.java:981)
      6. io.confluent.connect.avro.AvroData.toConnectData(AvroData.java:782)
      7. io.confluent.connect.avro.AvroConverter.toConnectData(AvroConverter.java:103)
      7 frames
    3. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:346)
      2. org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:226)
      3. org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:170)
      4. org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142)
      5. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
      6. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      6 frames
    4. Java RT
      ThreadPoolExecutor$Worker.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      2. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      3. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      4. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      4 frames