You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by at...@apache.org on 2026/10/11 18:22:56 UTC
(iceberg) branch main updated (140f4654bf -> 0b31766290)
This is an automated email from the ASF dual-hosted git repository.
laskoviymishka pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 140f4654bf Core: Drop equality_ids from v4 TrackedFile (#18427)
add 0b31766290 Kafka Connect: Preserve explicit null values instead of replacing them with schema defaults (#17653)
No new revisions were added by this update.
Summary of changes:
docs/docs/kafka-connect.md | 16 ++
.../iceberg/connect/transforms/CopyValue.java | 5 +-
.../connect/transforms/DebeziumTransform.java | 3 +-
.../connect/transforms/KafkaMetadataTransform.java | 3 +-
.../connect/transforms/MongoDebeziumTransform.java | 3 +-
.../iceberg/connect/transforms/TestCopyValue.java | 29 ++++
.../connect/transforms/TestDebeziumTransform.java | 22 ++-
.../transforms/TestKafkaMetadataTransform.java | 31 ++++
.../transforms/TestMongoDebeziumTransform.java | 33 ++++
.../apache/iceberg/connect/IcebergSinkConfig.java | 12 ++
.../iceberg/connect/data/RecordConverter.java | 37 ++++-
.../apache/iceberg/connect/data/RecordUtils.java | 18 ++-
.../apache/iceberg/connect/data/SinkWriter.java | 2 +-
.../iceberg/connect/TestIcebergSinkConfig.java | 1 +
.../iceberg/connect/data/TestRecordConverter.java | 173 +++++++++++++++++++++
.../iceberg/connect/data/TestRecordUtils.java | 78 ++++++++--
.../iceberg/connect/data/TestSinkWriter.java | 94 +++++++++++
17 files changed, 530 insertions(+), 30 deletions(-)