Modify exception description when deleting consumergroup if the consumer is active.

tinawenqiao · tinawenqiao · commit 708cc379f784 · 2018-05-11T16:04:20.000+08:00
diff --git a/src/main/java/org/gnuhpc/bigdata/service/KafkaAdminService.java b/src/main/java/org/gnuhpc/bigdata/service/KafkaAdminService.java
@@ -811,7 +811,7 @@ public GeneralResponse deleteConsumerGroup(String consumerGroup) {
                 zookeeperUtils.getCuratorClient().delete().deletingChildrenIfNeeded().forPath(CONSUMERPATHPREFIX + consumerGroup);
             } else {
                 if (!AdminUtils.deleteConsumerGroupInZK(zkUtils, consumerGroup)) {
-                    throw new ApiException(consumerGroup + " has not been deleted for some reason");
+                    throw new ApiException("The consumer " + consumerGroup + " is still active.Please stop it first");
                 }
             }
         } catch (Exception e) {

Original file line number	Diff line number	Diff line change
`@@ -811,7 +811,7 @@ public GeneralResponse deleteConsumerGroup(String consumerGroup) {`
`811`	`811`	`zookeeperUtils.getCuratorClient().delete().deletingChildrenIfNeeded().forPath(CONSUMERPATHPREFIX + consumerGroup);`
`812`	`812`	`} else {`
`813`	`813`	`if (!AdminUtils.deleteConsumerGroupInZK(zkUtils, consumerGroup)) {`
`814`		`- throw new ApiException(consumerGroup + " has not been deleted for some reason");`
	`814`	`+ throw new ApiException("The consumer " + consumerGroup + " is still active.Please stop it first");`
`815`	`815`	`}`
`816`	`816`	`}`
`817`	`817`	`} catch (Exception e) {`