添加开启与关闭消费队列

common-lib/src/main/java/com/mortals/xhx/queue/kafka/TbKafkaConsumerTemplate.java

 package com.mortals.xhx.queue.kafka;
 
 import com.mortals.xhx.queue.TbQueueMsg;
+import com.mortals.xhx.queue.TopicPartitionInfo;
 import lombok.Builder;
 import lombok.extern.apachecommons.CommonsLog;
 import lombok.extern.slf4j.Slf4j;
@@ -12,10 +13,7 @@ import org.slf4j.Logger;
 
 import java.io.IOException;
 import java.time.Duration;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Properties;
+import java.util.*;
 
 /**
  * kafka consumer 消费者模板
@@ -100,6 +98,11 @@ public class TbKafkaConsumerTemplate<T extends TbQueueMsg> extends AbstractTbQue
         // TbKafkaConsumerTemplate.builder().
     }
 
+    @Override
+    public void unsubscribe(Set<TopicPartitionInfo> partitions) {
+
+    }
+
     @Override
     public String getChannelNumber() {
         return "1231";