From d20a126a2dd8dc9a3edd262b2e5f1ebcbc26e3df Mon Sep 17 00:00:00 2001
From: Taranpreet Kaur <hundaltanu1997@gmail.com>
Date: Tue, 10 Mar 2026 21:58:36 +0530
Subject: [PATCH] tests in favor of Kafka-KRaft

---
 .../flink-sql-client-test/src/test/java/SqlClientITCase.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
index 676846527bdb9..be75ae5d81b51 100644
--- a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
+++ b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
@@ -81,6 +81,7 @@ public class SqlClientITCase {
     @Container
     public static final KafkaContainer KAFKA =
             new KafkaContainer(DockerImageName.parse(DockerImageVersions.KAFKA))
+                    .withKraft()
                     .withNetwork(NETWORK)
                     .withNetworkAliases(INTER_CONTAINER_KAFKA_ALIAS)
                     .withLogConsumer(LOG_CONSUMER);