Using Kafka snowflake connector, there are NOT NULL columns.
Getting below exception even before data ingestion start.
Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: Error inserting Records using Streaming API with msg:The given row cannot be converted to the internal format: Missing columns: Values for all non-nullable columns must be specified, rowIndex:0 (org.apache.kafka.connect.runtime.WorkerSinkTask:609)
org.apache.kafka.connect.errors.DataException: Error inserting Records using Streaming API with msg:The given row cannot be converted to the internal format: Missing columns: [AUDITDATE, RESOURCENAME, RESOURCEID]. Values for all non-nullable columns must be specified, rowIndex:0