删除队列同时删除对应topic

@@ -78,6 +78,7 @@ public class BusQueueController {
     public ResultJson deleteBusQueue(@RequestBody BusQueue busQueue)
     {
         try {
+            kafkaService.delTopic(busQueue.getQueueName());
             return busQueueService.deleteByPrimaryKey(busQueue.getId()) > 0
                     ? new ResultJson<>("200", "删除消息队列，成功")
                     : new ResultJson<>("500", "删除消息队列，失败");

@@ -19,7 +19,7 @@ public interface KafkaService {
     public void updateAdminclient();
     //by xyh
     boolean ediPartition(BusQueue record)throws ExecutionException, InterruptedException;
-
+    boolean delTopic(String topicName);
     /**
      * topic信息消费状况监控监控
      * @return

@@ -85,6 +85,7 @@ public class BusQueueServiceImpl implements BusQueueService {
             }
         } else {
             BusQueue busQueue = selectByPrimaryKey(id);
+            kafkaService.delTopic(busQueue.getQueueName());
             // 删除数据库中的该队列
             int num = busQueueMapper.deleteByPrimaryKey(id);
             // 删除MQ服务器上的队列

@@ -98,6 +98,12 @@ public class KafkaServiceImp implements KafkaService {
         return true;
     }
 
+    @Override
+    public boolean delTopic(String topicName) {
+        KAFKA_ADMIN_CLIENT.deleteTopics(Collections.singleton(topicName));
+        return false;
+    }
+
     /**
      * 获取topicList
      */