bryanck opened a new pull request, #9641: URL: https://github.com/apache/iceberg/pull/9641
This PR is the next stage in submitting the Iceberg Kafka Connect sink connector, and is a follow up to https://github.com/apache/iceberg/pull/8701 and https://github.com/apache/iceberg/pull/9466. It includes the record converters and the delta writers, with related config and tests. The delta writers are modeled after those in the Flink sink, and use equality deletes to apply deltas. Still not included in the sink are the commit controller, integration tests, or docs, which will be added in follow up PRs. For reference, the current sink implementation can be found at https://github.com/tabular-io/iceberg-kafka-connect. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org For additional commands, e-mail: issues-h...@iceberg.apache.org
