-
Bug
-
Resolution: Done
-
Major
-
1.8.1.Final
-
None
-
False
-
None
-
False
hi theres
When importing data from postgresql, sometimes the following specific error occurs.
Caused by: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "external_invoice_urls", schema type: ARRAY at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:220) at org.apache.kafka.connect.data.Struct.validate(Struct.java:233) at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:253) at org.apache.kafka.connect.data.Struct.put(Struct.java:216) at org.apache.kafka.connect.data.Struct.put(Struct.java:203) at io.debezium.data.Envelope.update(Envelope.java:323) at io.debezium.relational.RelationalChangeRecordEmitter.emitUpdateRecord(RelationalChangeRecordEmitter.java:111) at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:52) at io.debezium.connector.postgresql.PostgresChangeRecordEmitter.emitChangeRecords(PostgresChangeRecordEmitter.java:97) at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:215) ... 17 more
Since the external_invoice_urls column is a non-nullable value, there is no default value, and shouldn't a value always be passed in?
heres is table schema
SELECT column_name, is_nullable, data_type
FROM information_schema.COLUMNS
WHERE TABLE_NAME = 'reservations';
