Skip to content

Kafka Connect: Test Debezium tombstone handling - #18082

Open
zhangxinyao88 wants to merge 1 commit into
apache:mainfrom
zhangxinyao88:codex/issue-17326-debezium-tombstone-test
Open

zhangxinyao88 wants to merge 1 commit into
apache:mainfrom
zhangxinyao88:codex/issue-17326-debezium-tombstone-test

Conversation

@zhangxinyao88

Copy link
Copy Markdown

What

  • Cover tombstone records in DebeziumTransform.
  • Correct the existing test that used DmsTransform instead.
  • Verify the tombstone record is returned unchanged.

Tests

  • ./gradlew :iceberg-kafka-connect:iceberg-kafka-connect-transforms:test --tests org.apache.iceberg.connect.transforms.TestDebeziumTransform

AI Disclosure

@uros-b

uros-b commented Sep 14, 2026

Copy link
Copy Markdown
Member

Fix seems correct and complete, thank you @zhangxinyao88! Please ping active Kafka Connect committers, e.g. @twthorn or @pvary, for further review here

@zhangxinyao88

Copy link
Copy Markdown
Author

Fix seems correct and complete, thank you @zhangxinyao88! Please ping active Kafka Connect committers, e.g. @twthorn or @pvary, for further review here

@twthorn @pvary, could you take a look when you have a chance?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants