(beam) branch master updated: Pin Playground kafka-emulator to kafka-clients 2.4.1 (#39503)

[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 6741628d3af Pin Playground kafka-emulator to kafka-clients 2.4.1 
(#39503)
6741628d3af is described below

commit 6741628d3af452f7303ab94429134b4c221b10f8
Author: Abdelrahman Ibrahim <abdoibrahim1...@gmail.com>
AuthorDate: Mon Jul 27 18:08:01 2026 +0300

    Pin Playground kafka-emulator to kafka-clients 2.4.1 (#39503)
---
 playground/kafka-emulator/build.gradle | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/playground/kafka-emulator/build.gradle 
b/playground/kafka-emulator/build.gradle
index 17bb9de948d..62f6001c76c 100644
--- a/playground/kafka-emulator/build.gradle
+++ b/playground/kafka-emulator/build.gradle
@@ -23,6 +23,17 @@ 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.
+// TODO: Migrate embedded-kafka to 3.9.2.
+// 
https://mvnrepository.com/artifact/io.github.embeddedkafka/embedded-kafka_2.12/3.9.2
+configurations.all {
+   resolutionStrategy {
+      force 'org.apache.kafka:kafka-clients:2.4.1'
+   }
+}
+
 distZip {
    archiveFileName = "${archiveBaseName.get()}.zip"
 }