I'm running in to an exception when starting what I think is normal operation.
I'm running all services in standalone mode following the guide: ZK, kafka, schema-registry, kafka-connect. I have a table with ~360k entries, and I have verified that the id and timestamp columns are not nullable and do not contain nulls. Here's my config:
name=postgres
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:postgresql://localhost:5432/umod?user=***&password=***
mode=timestamp+incrementing
topic.prefix=mb-
table.whitelist=board_comment
And the stack trace:
[2016-03-30 17:35:48,356] ERROR Task postgres-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerSourceTask:362)
[2016-03-30 17:35:48,356] ERROR Task is being killed and will not recover until manually restarted: (org.apache.kafka.connect.runtime.WorkerSourceTask:363)
org.apache.kafka.connect.errors.DataException: Found null value for non-optional schema
at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:299)
at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:450)
at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:267)
at io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:90)
at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:142)
at org.apache.kafka.connect.runtime.WorkerSourceTask.access$600(WorkerSourceTask.java:50)
at org.apache.kafka.connect.runtime.WorkerSourceTask$WorkerSourceTaskThread.execute(WorkerSourceTask.java:356)
at org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)