Got the error 

Caused by: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "created_at", schema type: STRING

. Is there a way, I can switch off the validation for the null values, or ignore the failing data alone?