local change

Signed-off-by: Yupeng Fu <yupeng@uber.com>

buildSrc/src/main/java/org/opensearch/gradle/testclusters/RunTask.java

@@ -52,6 +52,8 @@
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
+import static org.gradle.internal.classpath.Instrumented.systemProperty;
+
 /**
  * Implementation of the "run" Gradle task used in run.gradle
  */
@@ -179,16 +181,19 @@ public void beforeStart() {
                 if (dataDir != null) {
                     node.setDataPath(getDataPath.apply(node));
                 }
+
                 if (debug) {
                     logger.lifecycle(
                         "Running opensearch in debug mode (client), {} expecting running debug server on port {}",
                         node,
                         debugPort
                     );
+//                    node.systemProperty("java.security.manager", "");
                     node.jvmArgs("-agentlib:jdwp=transport=dt_socket,server=n,suspend=y,address=" + debugPort);
                     debugPort += 1;
                 } else if (debugServer) {
                     logger.lifecycle("Running opensearch in debug mode (server), {} running server with debug port {}", node, debugPort);
+//                    node.systemProperty("java.security.manager", "");
                     node.jvmArgs("-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=" + debugPort);
                     debugPort += 1;
                 }

server/build.gradle

@@ -114,7 +114,7 @@ dependencies {
   // kafka
   api "org.slf4j:slf4j-api:${versions.slf4j}"
   implementation "org.apache.logging.log4j:log4j-slf4j-impl:${versions.log4j}"
-  api "org.apache.kafka:kafka-clients:3.9.0"
+  api "org.apache.kafka:kafka-clients:2.8.2"
 
   // test
 //  api "org.testcontainers:testcontainers:1.20.3"