diff --git a/sdks/go/test/integration/io/xlang/debezium/debezium_test.go b/sdks/go/test/integration/io/xlang/debezium/debezium_test.go
index 24c2b513b2b2..208a062f9436 100644
--- a/sdks/go/test/integration/io/xlang/debezium/debezium_test.go
+++ b/sdks/go/test/integration/io/xlang/debezium/debezium_test.go
@@ -34,7 +34,7 @@ import (
 )
 
 const (
-	debeziumImage = "debezium/example-postgres:latest"
+	debeziumImage = "quay.io/debezium/example-postgres:latest"
 	debeziumPort  = "5432/tcp"
 	maxRetries    = 5
 )
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 2bfa694aebc0..970d9483850c 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("debezium/example-postgres:latest")
+              DockerImageName.parse("quay.io/debezium/example-postgres:latest")
                   .asCompatibleSubstituteFor("postgres"))
           .withPassword("dbz")
           .withUsername("debezium")
diff --git a/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformTest.java b/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformTest.java
index c75621040913..c4b5d2d1f890 100644
--- a/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformTest.java
+++ b/sdks/java/io/debezium/src/test/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformTest.java
@@ -46,7 +46,7 @@ public class DebeziumReadSchemaTransformTest {
   @ClassRule
   public static final PostgreSQLContainer<?> POSTGRES_SQL_CONTAINER =
       new PostgreSQLContainer<>(
-              DockerImageName.parse("debezium/example-postgres:latest")
+              DockerImageName.parse("quay.io/debezium/example-postgres:latest")
                   .asCompatibleSubstituteFor("postgres"))
           .withPassword("dbz")
           .withUsername("debezium")
diff --git a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java
index eddcb0de5561..266d04342d1f 100644
--- a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java
+++ b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java
@@ -215,7 +215,7 @@ public void testPublishingThenReadingAll() throws IOException, JMSException {
     int unackRecords = countRemain(QUEUE);
     assertTrue(
         String.format("Too many unacknowledged messages: %d", unackRecords),
-        unackRecords < OPTIONS.getNumberOfRecords() * 0.002);
+        unackRecords < OPTIONS.getNumberOfRecords() * 0.003);
 
     // acknowledged records
     int ackRecords = OPTIONS.getNumberOfRecords() - unackRecords;
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 7829baba8b69..abe9530787e8 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
@@ -107,7 +107,7 @@ def start_db_container(self, retries):
     for i in range(retries):
       try:
         self.db = PostgresContainer(
-            'debezium/example-postgres:latest',
+            'quay.io/debezium/example-postgres:latest',
             user=self.username,
             password=self.password,
             dbname=self.database)