This is an automated email from the ASF dual-hosted git repository.
ahmedabualsaud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 9c9de4919b5 Update Go container build version to 1.21.11 (#31515)
add f2931d31246 Kafka SchemaTransform translation (#31362)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 +-
.../KafkaReadSchemaTransformConfiguration.java | 6 +
.../io/kafka/KafkaReadSchemaTransformProvider.java | 260 +++++++++++----------
.../io/kafka/KafkaSchemaTransformTranslation.java} | 45 ++--
.../kafka/KafkaWriteSchemaTransformProvider.java | 16 ++
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 45 ++--
.../KafkaReadSchemaTransformProviderTest.java | 48 ++--
.../kafka/KafkaSchemaTransformTranslationTest.java | 216 +++++++++++++++++
8 files changed, 453 insertions(+), 185 deletions(-)
copy
sdks/java/io/{iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergSchemaTransformTranslation.java
=>
kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaSchemaTransformTranslation.java}
(60%)
create mode 100644
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaSchemaTransformTranslationTest.java
