From 68c5b95937ea15a7d6e3df034b38014d2cb92f93 Mon Sep 17 00:00:00 2001 From: Chamikara Jayalath Date: Wed, 30 Apr 2025 12:15:23 -0700 Subject: [PATCH] Adjusting the YAML Kafka Managed I/O compat version --- sdks/python/apache_beam/yaml/standard_io.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/yaml/standard_io.yaml b/sdks/python/apache_beam/yaml/standard_io.yaml index c6713725025e..15d3ccd3dda0 100644 --- a/sdks/python/apache_beam/yaml/standard_io.yaml +++ b/sdks/python/apache_beam/yaml/standard_io.yaml @@ -88,8 +88,8 @@ # Following transforms may be replaced with equivalent managed transforms, # if the pipelines 'updateCompatibilityBeamVersion' match the provided # version. - 'ReadFromKafka': '2.66.0' - 'WriteToKafka': '2.66.0' + 'ReadFromKafka': '2.65.0' + 'WriteToKafka': '2.65.0' # PubSub - type: renaming