This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch fix-postcommit-python
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/fix-postcommit-python by this
push:
new 7799a86104a Fix debezium port type
7799a86104a is described below
commit 7799a86104a4147979a77837d444ea4446eb817d
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Fri Jul 25 13:42:05 2025 +0400
Fix debezium port type
---
sdks/python/apache_beam/io/debezium.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/debezium.py
b/sdks/python/apache_beam/io/debezium.py
index e6f3290d06a..02173662092 100644
--- a/sdks/python/apache_beam/io/debezium.py
+++ b/sdks/python/apache_beam/io/debezium.py
@@ -155,7 +155,7 @@ class ReadFromDebezium(PTransform):
username=username,
password=password,
host=host,
- port=port,
+ port=str(port),
max_number_of_records=max_number_of_records,
connection_properties=connection_properties)
self.expansion_service = expansion_service or
default_io_expansion_service()
