From 991bf4ecf19dc79b246be160ab1d89efd6032b38 Mon Sep 17 00:00:00 2001
From: wycccccc <493172422@qq.com>
Date: Tue, 8 Mar 2022 14:46:19 +0800
Subject: [PATCH] removeJmxServer

---
 .../main/java/org/astraea/performance/Performance.java    | 8 --------
 .../java/org/astraea/performance/PerformanceTest.java     | 7 -------
 2 files changed, 15 deletions(-)

diff --git a/app/src/main/java/org/astraea/performance/Performance.java b/app/src/main/java/org/astraea/performance/Performance.java
index 8b52174698..aad648d005 100644
--- a/app/src/main/java/org/astraea/performance/Performance.java
+++ b/app/src/main/java/org/astraea/performance/Performance.java
@@ -282,13 +282,6 @@ public static class Argument extends org.astraea.argument.Argument {
         converter = DataSize.Field.class)
     DataSize recordSize = DataUnit.KiB.of(1);
 
-    @Parameter(
-        names = {"--jmx.servers"},
-        description =
-            "String: server to get jmx metrics <jmx_server>@<broker_id>[,<jmx_server>@<broker_id>]*",
-        validateWith = NonEmptyStringField.class)
-    String jmxServers = "";
-
     @Parameter(
         names = {"--partitioner"},
         description = "String: the full class name of the desired partitioner",
@@ -305,7 +298,6 @@ public static class Argument extends org.astraea.argument.Argument {
     public Map<String, Object> producerProps() {
       var props = props();
       props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, compression.name);
-      if (!this.jmxServers.isEmpty()) props.put("jmx_servers", this.jmxServers);
       props.putAll(configs);
       return props;
     }
diff --git a/app/src/test/java/org/astraea/performance/PerformanceTest.java b/app/src/test/java/org/astraea/performance/PerformanceTest.java
index a753be5ee8..43d9ed8401 100644
--- a/app/src/test/java/org/astraea/performance/PerformanceTest.java
+++ b/app/src/test/java/org/astraea/performance/PerformanceTest.java
@@ -173,8 +173,6 @@ void testArgument() {
       "1000records",
       "--record.size",
       "10KiB",
-      "--jmx.servers",
-      "localhost:9000@1",
       "--partitioner",
       "org.astraea.partitioner.smoothPartitioner.SmoothWeightPartitioner",
       "--compression",
@@ -224,11 +222,6 @@ void testArgument() {
         IllegalArgumentException.class,
         () -> org.astraea.argument.Argument.parse(new Performance.Argument(), arguments8));
 
-    String[] arguments9 = {"--bootstrap.servers", "localhost:9092", "--jmx.servers", ""};
-    Assertions.assertThrows(
-        ParameterException.class,
-        () -> org.astraea.argument.Argument.parse(new Performance.Argument(), arguments9));
-
     String[] arguments10 = {"--bootstrap.servers", "localhost:9092", "--partitioner", ""};
     Assertions.assertThrows(
         ParameterException.class,