Close kafkaZKClient in stop reassign partitions. Clear some test data.

Author: tinawenqiao

docs/index.pdf

@@ -92,8 +92,6 @@ public Map<Integer, Map<String, LogDirInfo>> describeLogDirs(
       @RequestParam(required = false) List<Integer> brokerList,
       @RequestParam(required = false) List<String> logDirList,
       @RequestParam(required = false) Map<String, List<Integer>> topicPartitionMap) {
-    topicPartitionMap.clear();
-    topicPartitionMap.put("__consumer_offsets", Arrays.asList(15, 16, 48));
     return kafkaAdminService.describeLogDirsByBrokerAndTopic(brokerList, logDirList, topicPartitionMap);
   }
 
@@ -311,7 +309,7 @@ public ConsumerGroupMeta getConsumerGroupMeta(@PathVariable String consumerGroup
   @GetMapping(value = "/consumergroups/meta")
   @ApiOperation(
       value =
-          "Get the meta data of the specified new consumer groups, including state, coordinator,"
+          "Get all the meta data of new consumer groups, including state, coordinator,"
               + " assignmentStrategy, members")
   public List<ConsumerGroupMeta> getConsumerGroupsMeta() {
     Set<String> consumerGroupList = kafkaAdminService.listAllNewConsumerGroups();

src/main/java/org/gnuhpc/bigdata/controller/KafkaController.java

@@ -1843,6 +1843,7 @@ public GeneralResponse stopReassignPartitions() {
       log.info("Delete zk path /admin/reassign_partitions failed.");
     }
 
+    kafkaZkClient.close();
     return response;
   }