(beam) branch master updated: Bump the KafkaToPubsubE2ETest emulator image to an existing tag (#39956)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 0ba44c65b80 Bump the KafkaToPubsubE2ETest emulator image to an 
existing tag (#39956)
0ba44c65b80 is described below

commit 0ba44c65b8001226190a1ee892549360ddde9f6d
Author: Tobias Kaymak <tobias.kay...@gmail.com>
AuthorDate: Tue Sep 1 16:32:45 2026 +0200

    Bump the KafkaToPubsubE2ETest emulator image to an existing tag (#39956)
    
    gcr.io purged the 316.0.0 tag family, so the pinned
    cloud-sdk:316.0.0-emulators image 404s and the PubSub emulator container
    fails in the class rule
---
 .../beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java
 
b/examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java
index 7639064a27d..e5ca54a59f4 100644
--- 
a/examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java
+++ 
b/examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java
@@ -53,7 +53,7 @@ import org.testcontainers.utility.DockerImageName;
 /** E2E test for {@link KafkaToPubsub} pipeline. */
 public class KafkaToPubsubE2ETest {
   private static final String PUBSUB_EMULATOR_IMAGE =
-      "gcr.io/google.com/cloudsdktool/cloud-sdk:316.0.0-emulators";
+      "gcr.io/google.com/cloudsdktool/cloud-sdk:583.0.0-emulators";
   private static final String KAFKA_IMAGE_NAME = "confluentinc/cp-kafka:5.4.3";
   private static final String PUBSUB_MESSAGE = "test pubsub message";
   private static final String KAFKA_TOPIC_NAME = "messages-topic";