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

Amar3tto pushed a commit to branch fix-playground-nightly
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/fix-playground-nightly by this 
push:
     new c43e4ffaa44 pin kafka emulator
c43e4ffaa44 is described below

commit c43e4ffaa44d616c8d863f6d8dee04b03b72d096
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Mon Jul 27 17:41:05 2026 +0400

    pin kafka emulator
---
 .github/workflows/beam_Playground_CI_Nightly.yml | 2 +-
 playground/kafka-emulator/build.gradle           | 9 +++++++++
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git a/.github/workflows/beam_Playground_CI_Nightly.yml 
b/.github/workflows/beam_Playground_CI_Nightly.yml
index 484ef0be243..e13d18d4850 100644
--- a/.github/workflows/beam_Playground_CI_Nightly.yml
+++ b/.github/workflows/beam_Playground_CI_Nightly.yml
@@ -67,7 +67,7 @@ jobs:
       - name: Setup environment
         uses: ./.github/actions/setup-environment-action
         with:
-          python-version: '3.11'
+          python-version: default
           go-version: '1.26'
       - name: Install requirements
         run: |
diff --git a/playground/kafka-emulator/build.gradle 
b/playground/kafka-emulator/build.gradle
index 17bb9de948d..3fd7d0cb4f0 100644
--- a/playground/kafka-emulator/build.gradle
+++ b/playground/kafka-emulator/build.gradle
@@ -23,6 +23,15 @@ plugins {
 
 applyJavaNature(exportJavadoc: false, publish: false)
 
+// embedded-kafka 2.4.1.1 requires kafka-clients 2.4.1. BeamModulePlugin forces
+// kafka-clients to the Beam-wide kafka_version (3.9.2+ after #39284), which
+// prevents the emulator from binding and blocks every Playground RunCode call.
+configurations.all {
+  resolutionStrategy {
+    force 'org.apache.kafka:kafka-clients:2.4.1'
+  }
+}
+
 distZip {
    archiveFileName = "${archiveBaseName.get()}.zip"
 }

Reply via email to