Merge branch 'main' into feature/connector-failed-modal

Author: mehmetcangulesci

.github/CODEOWNERS

@@ -16,7 +16,7 @@ gradle/libs.versions.toml   @kafbat/backend
 /frontend/                  @kafbat/frontend
 
 # TESTS
-/e2e-tests/                 @kafbat/qa
+/e2e-playwright/                 @kafbat/qa
 
 # INFRA
 /.github/workflows/         @kafbat/devops

.github/dependabot.yml

@@ -11,6 +11,11 @@ updates:
   labels:
     - "type/dependencies"
     - "scope/backend"
+  ignore:
+    # Disable dependabot pull requests for Netty
+    # In general, our Netty references are temporary overrides, usually applied to address transitive Spring vulnerabilities, and should be configured with caution
+    # In general, having conflicting Netty versions in the classpath is not recommended
+    - dependency-name: "io.netty:*"
   groups:
     spring-boot-dependencies:
       patterns:
@@ -23,16 +28,10 @@ updates:
       exclude-patterns:
           - "org.springframework.boot:*"
           - "io.spring.dependency-management"
-          # All netty references are temporary overwrites that must be set carefully
-          # We do not need dependabot to send pull requests
-          - "io.netty:*"    
     other-dependencies:
       exclude-patterns:
         - "org.springframework.boot:*"
         - "io.spring.dependency-management"
-        # All netty references are temporary overwrites that must be set carefully
-        # We do not need dependabot to send pull requests
-        - "io.netty:*"
       patterns:
         - "*"
       update-types:

.github/workflows/e2e-manual.yml

@@ -58,10 +58,7 @@ jobs:
       - name: Build with Gradle
         id: build_app
         run: |
-          ./gradlew build \
-          -x :e2e-tests:check \
-          -x :e2e-tests:build \
-          -x test \
+          ./gradlew build -x test \
           -Pbuild-docker-images=true \
           -Pinclude-frontend=true \
           -Pversion=latest

.github/workflows/e2e-playwright-run.yml

@@ -72,12 +72,6 @@ dependencies {
     // CVE Fixes
     implementation libs.apache.commons.compress
     implementation libs.okhttp3.logging.intercepter
-    // START Fixes https://www.cve.org/CVERecord?id=CVE-2025-58056 and https://www.cve.org/CVERecord?id=CVE-2025-58057
-    implementation libs.netty.codec
-    implementation libs.netty.codec.http
-    // END Fixes https://www.cve.org/CVERecord?id=CVE-2025-58056 and https://www.cve.org/CVERecord?id=CVE-2025-58057
-    // CVE Fixes End
-
 
     implementation libs.modelcontextprotocol.spring.webflux
     implementation libs.victools.jsonschema.generator

.github/workflows/e2e-pr.yml

@@ -43,6 +43,19 @@ public class ClustersProperties {
   CacheProperties cache = new CacheProperties();
   ClusterFtsProperties fts = new ClusterFtsProperties();
 
+  AdminClient adminClient = new AdminClient();
+
+  @Data
+  public static class AdminClient {
+    Integer timeout;
+    int describeConsumerGroupsPartitionSize = 50;
+    int describeConsumerGroupsConcurrency = 4;
+    int listConsumerGroupOffsetsPartitionSize = 50;
+    int listConsumerGroupOffsetsConcurrency = 4;
+    int getTopicsConfigPartitionSize = 200;
+    int describeTopicsPartitionSize = 200;
+  }
+
   @Data
   public static class Cluster {
     @NotBlank(message = "field name for for cluster could not be blank")

.github/workflows/e2e-run.yml

@@ -26,9 +26,21 @@
 public class ClientQuotasController extends AbstractController implements ClientQuotasApi, McpTool {
 
   private static final Comparator<ClientQuotaRecord> QUOTA_RECORDS_COMPARATOR =
-      Comparator.nullsLast(Comparator.comparing(ClientQuotaRecord::user))
-          .thenComparing(Comparator.nullsLast(Comparator.comparing(ClientQuotaRecord::clientId)))
-          .thenComparing(Comparator.nullsLast(Comparator.comparing(ClientQuotaRecord::ip)));
+          Comparator.nullsLast(
+            Comparator.comparing(ClientQuotaRecord::user, Comparator.nullsLast(String::compareTo))
+          )
+          .thenComparing(Comparator.nullsLast(
+              Comparator.comparing(
+                  ClientQuotaRecord::clientId,
+                  Comparator.nullsLast(String::compareTo)
+              )
+          ))
+          .thenComparing(Comparator.nullsLast(
+              Comparator.comparing(
+                  ClientQuotaRecord::ip,
+                  Comparator.nullsLast(String::compareTo)
+              )
+          ));
 
   private final ClientQuotaService clientQuotaService;