Aiven-Open / Aiven-Open/cloud-storage-connectors-for-apache-kafka
Handling tombstone events
Aperta
GCS
- Lingua principale
- Java
- Stelle
- 58
- Fork
- 39
- Merge medio
- 2g 10h
- PR unite (30g)
- 5
Descrizione
I am trying to use the connector for writing postgres CDC data [(Debezium connector for PostgreSQL)](https://debezium.io/documentation/reference/stable/connectors/postgresql.html) 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?
Guida per i contributori
Apri la guida per i contributori
Valutazione
Questa issue non è ancora stata valutata.