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

GitHub | sanchitgrover | 6 months ago
  1. 0

    Records containing union schemas with enums are not handled properly.

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

    NullPointerException when using Avro converter

    GitHub | 1 year ago | Arttii
    java.lang.NullPointerException
  3. 0

    Using Array of Records in AVRO with kafka connect

    Google Groups | 10 months ago | Unknown author
    java.lang.NullPointerException
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Error while writing to HDFS using Kafka HDFS Connect

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

    Did not find matching union field for data

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

    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
      Thread.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)
      5. java.lang.Thread.run(Thread.java:745)
      5 frames