org.apache.kafka.connect.errors.DataException: Found null value for non-optional schema

Google Groups | Chris Retford | 11 months ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    Found null value for non-optional schema

    Google Groups | 11 months ago | Chris Retford
    org.apache.kafka.connect.errors.DataException: Found null value for non-optional schema
  2. 0

    using confluent fromm kafka to hdfs: ERROR Task test-mysql-jdbc-autoincrement-source-0 threw an unc

    Google Groups | 10 months ago | Kotesh Banoth
    org.apache.kafka.connect.errors.DataException: Failed to serialize Avro data:
  3. 0

    Connect JDBC Connector Schema Evolution possible?

    Google Groups | 9 months ago | Jim Malone
    org.apache.kafka.connect.errors.DataException: Failed to serialize Avro data :
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    1 unregistered visitors

    Root Cause Analysis

    1. org.apache.kafka.connect.errors.DataException

      Found null value for non-optional schema

      at io.confluent.connect.avro.AvroData.fromConnectData()
    2. io.confluent.connect
      AvroConverter.fromConnectData
      1. io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:299)
      2. io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:450)
      3. io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:267)
      4. io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:90)
      4 frames
    3. org.apache.kafka
      ShutdownableThread.run
      1. org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:142)
      2. org.apache.kafka.connect.runtime.WorkerSourceTask.access$600(WorkerSourceTask.java:50)
      3. org.apache.kafka.connect.runtime.WorkerSourceTask$WorkerSourceTaskThread.execute(WorkerSourceTask.java:356)
      4. org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)
      4 frames