From a1708107e55b6b82afc05d9ad2e1cf4bfbd1add6 Mon Sep 17 00:00:00 2001
From: smartloli <smartloli.org@gmail.com>
Date: Sat, 23 Nov 2019 23:53:25 +0800
Subject: [PATCH] add modify topic partitions

---
 .../kafka/eagle/web/controller/TopicController.java   |  4 ++--
 .../kafka/eagle/web/quartz/MetricsQuartz.java         | 11 +++++++++++
 2 files changed, 13 insertions(+), 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
index 4aef3d13..11129f9e 100644
--- 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
index 66208865..76a0e57c 100644
--- 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() {