Upgrade to debezium-io 3.1.3 (#37571)

Thanks!

Author: tkaymak

sdks/java/io/debezium/build.gradle

@@ -49,7 +49,7 @@ dependencies {
     implementation "org.apache.kafka:connect-api:3.9.0"
 
     // Debezium dependencies
-    implementation group: 'io.debezium', name: 'debezium-core', version: '3.1.1.Final'
+    implementation group: 'io.debezium', name: 'debezium-core', version: '3.1.3.Final'
 
     // Test dependencies
     testImplementation project(path: ":sdks:java:core", configuration: "shadowTest")
@@ -64,12 +64,12 @@ dependencies {
     testImplementation "org.testcontainers:kafka"
     testImplementation "org.testcontainers:mysql"
     testImplementation "org.testcontainers:postgresql"
-    testImplementation "io.debezium:debezium-testing-testcontainers:3.1.1.Final"
+    testImplementation "io.debezium:debezium-testing-testcontainers:3.1.3.Final"
     testImplementation 'com.zaxxer:HikariCP:5.1.0'
 
     // Debezium connector implementations for testing
-    testImplementation group: 'io.debezium', name: 'debezium-connector-mysql', version: '3.1.1.Final'
-    testImplementation group: 'io.debezium', name: 'debezium-connector-postgres', version: '3.1.1.Final'
+    testImplementation group: 'io.debezium', name: 'debezium-connector-mysql', version: '3.1.3.Final'
+    testImplementation group: 'io.debezium', name: 'debezium-connector-postgres', version: '3.1.3.Final'
 }
 
 // Pin the Antlr version to 4.10

sdks/java/io/debezium/expansion-service/build.gradle

@@ -39,7 +39,7 @@ dependencies {
     runtimeOnly library.java.slf4j_jdk14
 
     // Debezium runtime dependencies
-    def debezium_version = '3.1.1.Final'
+    def debezium_version = '3.1.3.Final'
     runtimeOnly group: 'io.debezium', name: 'debezium-connector-mysql', version: debezium_version
     runtimeOnly group: 'io.debezium', name: 'debezium-connector-postgres', version: debezium_version
     runtimeOnly group: 'io.debezium', name: 'debezium-connector-sqlserver', version: debezium_version

sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOMySqlConnectorIT.java

@@ -74,7 +74,7 @@ public class DebeziumIOMySqlConnectorIT {
   @ClassRule
   public static final MySQLContainer<?> MY_SQL_CONTAINER =
       new MySQLContainer<>(
-              DockerImageName.parse("quay.io/debezium/example-mysql:3.1.1.Final")
+              DockerImageName.parse("quay.io/debezium/example-mysql:3.1.3.Final")
                   .asCompatibleSubstituteFor("mysql"))
           .withPassword("debezium")
           .withUsername("mysqluser")
@@ -277,7 +277,7 @@ public void testDebeziumIOMySql() {
                 .withMaxNumberOfRecords(30)
                 .withCoder(StringUtf8Coder.of()));
     String expected =
-        "{\"metadata\":{\"connector\":\"mysql\",\"version\":\"3.1.1.Final\",\"name\":\"beam-debezium-connector\","
+        "{\"metadata\":{\"connector\":\"mysql\",\"version\":\"3.1.3.Final\",\"name\":\"beam-debezium-connector\","
             + "\"database\":\"inventory\",\"schema\":\"binlog.000002\",\"table\":\"addresses\"},\"before\":null,"
             + "\"after\":{\"fields\":{\"zip\":\"76036\",\"city\":\"Euless\","
             + "\"street\":\"3183 Moore Avenue\",\"id\":10,\"state\":\"Texas\",\"customer_id\":1001,"

sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOPostgresSqlConnectorIT.java

@@ -56,7 +56,7 @@ public class DebeziumIOPostgresSqlConnectorIT {
   @ClassRule
   public static final PostgreSQLContainer<?> POSTGRES_SQL_CONTAINER =
       new PostgreSQLContainer<>(
-              DockerImageName.parse("quay.io/debezium/example-postgres:3.1.1.Final")
+              DockerImageName.parse("quay.io/debezium/example-postgres:3.1.3.Final")
                   .asCompatibleSubstituteFor("postgres"))
           .withPassword("dbz")
           .withUsername("debezium")
@@ -180,7 +180,7 @@ public void testDebeziumIOPostgresSql() {
                 .withMaxNumberOfRecords(30)
                 .withCoder(StringUtf8Coder.of()));
     String expected =
-        "{\"metadata\":{\"connector\":\"postgresql\",\"version\":\"3.1.1.Final\",\"name\":\"beam-debezium-connector\","
+        "{\"metadata\":{\"connector\":\"postgresql\",\"version\":\"3.1.3.Final\",\"name\":\"beam-debezium-connector\","
             + "\"database\":\"inventory\",\"schema\":\"inventory\",\"table\":\"customers\"},\"before\":null,"
             + "\"after\":{\"fields\":{\"last_name\":\"Thomas\",\"id\":1001,\"first_name\":\"Sally\","
             + "\"email\":\"sally.thomas@acme.com\"}}}";

sdks/python/apache_beam/io/external/xlang_debeziumio_it_test.py

@@ -89,7 +89,7 @@ def test_xlang_debezium_read(self):
     expected_response = [{
         "metadata": {
             "connector": "postgresql",
-            "version": "3.1.1.Final",
+            "version": "3.1.3.Final",
             "name": "beam-debezium-connector",
             "database": "inventory",
             "schema": "inventory",