gcs-connector-for-apache-kafka icon indicating copy to clipboard operation
gcs-connector-for-apache-kafka copied to clipboard
verified publisher icon Aiven-Open

Handling tombstone events

Open kobynet opened this issue 1 year ago • 0 comments

I am trying to use the connector for writing postgres CDC data (Debezium connector for PostgreSQL) in parquet format to GCS.

When there is a tombstone record (value is null) then the following error is thrown "Record must have schemas for key and value"

Just for comparison, in confluent s3 connector there is a "behavior.on.null.values" just for that case, does this connector have similar way of handling such scenario?

kobynet avatar Jul 02 '24 09:07 kobynet