add modify topic partitions

dudefu · Nov 23, 2019 · a170810 · a170810
1 parent b2ce2bd
commit a170810
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/kafka-eagle-web/src/main/java/org/smartloli/kafka/eagle/web/controller/TopicController.java b/kafka-eagle-web/src/main/java/org/smartloli/kafka/eagle/web/controller/TopicController.java
@@ -357,10 +357,10 @@ public void topicListAjax(HttpServletResponse response, HttpServletRequest reque
 			object.put("created", partition.getCreated());
 			object.put("modify", partition.getModify());
 			if (Role.ADMIN.equals(signiner.getUsername())) {
+				// <li><a href='#" + partition.getTopic() + "' name='topic_clean'><i class='fa fa-fw fa-trash-o'></i>Clean</a></li>
 				object.put("operate",
 						"<div class='btn-group'><button class='btn btn-primary btn-xs dropdown-toggle' type='button' data-toggle='dropdown' aria-haspopup='true' aria-expanded='false'>Action <span class='caret'></span></button><ul class='dropdown-menu dropdown-menu-right'><li><a name='topic_modify' href='#"
-								+ partition.getTopic() + "'><i class='fa fa-fw fa-edit'></i>Modify</a></li><li><a href='#" + partition.getTopic() + "' name='topic_clean'><i class='fa fa-fw fa-trash-o'></i>Clean</a></li><li><a href='#"
-								+ partition.getTopic() + "' name='topic_remove'><i class='fa fa-fw fa-minus-circle'></i>Remove</a></li></ul></div>");
+								+ partition.getTopic() + "'><i class='fa fa-fw fa-edit'></i>Modify</a></li><li><a href='#" + partition.getTopic() + "' name='topic_remove'><i class='fa fa-fw fa-minus-circle'></i>Remove</a></li></ul></div>");
 			} else {
 				object.put("operate", "");
 			}

diff --git a/kafka-eagle-web/src/main/java/org/smartloli/kafka/eagle/web/quartz/MetricsQuartz.java b/kafka-eagle-web/src/main/java/org/smartloli/kafka/eagle/web/quartz/MetricsQuartz.java
@@ -65,6 +65,17 @@ public void metricsConsumerTopicQuartz() {
 			LOG.error("Collector consumer topic data has error, msg is " + e.getCause().getMessage());
 			e.printStackTrace();
 		}
+
+		try {
+			checkCleanTopicTaskProcess();
+		} catch (Exception e) {
+			LOG.error("Check clean topic task whether is finished has error, msg is " + e.getCause().getMessage());
+			e.printStackTrace();
+		}
+	}
+
+	private void checkCleanTopicTaskProcess() {
+		// TODO
 	}
 
 	private void consumerTopicQuartz() {