org.apache.kafka.connect.errors.DataException

Conversion error: null value for field that is required and has no default value


Solutions on the web47

Solution icon of stackoverflow
Conversion error: null value for field that is required and has no default value

Solution icon of github
Conversion error: null value for field that is required and has no default value

Solution icon of stackoverflow
Conversion error: null value for field that is required and has no default value

Solution icon of googlegroups
via Google Groups by Chris Retford, 10 months ago
Found null value for non-optional schema

Solution icon of googlegroups
Found null value for non-optional schema

Solution icon of github
via GitHub by hanshenrik
, 6 months ago
BigDecimal has mismatching scale value for given Decimal schema

Solution icon of googlegroups
via Google Groups by Unmesh Joshi, 1 year ago
BigDecimal has mismatching scale value for given Decimal schema

Solution icon of github
BigDecimal has mismatching scale value for given Decimal schema

Solution icon of googlegroups
created_dt is not a valid field name

Solution icon of github
Did not find matching union field for data: PROD

Stack trace

  • org.apache.kafka.connect.errors.DataException: Conversion error: null value for field that is required and has no default value at org.apache.kafka.connect.json.JsonConverter.convertToJson(JsonConverter.java:556) at org.apache.kafka.connect.json.JsonConverter.convertToJsonWithEnvelope(JsonConverter.java:537) at org.apache.kafka.connect.json.JsonConverter.fromConnectData(JsonConverter.java:291) at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:182) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:160) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)

Write tip

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

Users with the same issue

You are the first who have seen this exception. Write a tip to help other users and build your expert profile.