diff --git a/sdks/java/io/debezium/build.gradle b/sdks/java/io/debezium/build.gradle index 521b9ab56106..c488ac17d990 100644 --- a/sdks/java/io/debezium/build.gradle +++ b/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 diff --git a/sdks/java/io/debezium/expansion-service/build.gradle b/sdks/java/io/debezium/expansion-service/build.gradle index cd7e527e9cec..82a34b5c0665 100644 --- a/sdks/java/io/debezium/expansion-service/build.gradle +++ b/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 diff --git a/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOMySqlConnectorIT.java b/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOMySqlConnectorIT.java index e926a4b30625..0d4d02e1cff6 100644 --- a/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOMySqlConnectorIT.java +++ b/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," diff --git a/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOPostgresSqlConnectorIT.java b/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOPostgresSqlConnectorIT.java index c1f67e4e44d9..87b9bbb92e5e 100644 --- a/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumIOPostgresSqlConnectorIT.java +++ b/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\"}}}"; diff --git a/sdks/python/apache_beam/io/external/xlang_debeziumio_it_test.py b/sdks/python/apache_beam/io/external/xlang_debeziumio_it_test.py index d20a64466323..30b96f01a1a5 100644 --- a/sdks/python/apache_beam/io/external/xlang_debeziumio_it_test.py +++ b/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",