Aiven-Open / Aiven-Open/cloud-storage-connectors-for-apache-kafka

Handling tombstone events

未关闭
#254 2 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看
GCS
主要语言
Java
星标
58
派生
39
平均合并
2 天 10 小时
30 天内合并 PR
5

描述

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?

贡献指南

打开贡献指南

评估

这个 Issue 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。