bugfix: uncomment kafka listener

src/main/java/com/dragon/tj/portal/component/message/MessageConsumer.java

@@ -45,7 +45,7 @@ public class MessageConsumer {
      * @param msg
      * @param ack
      */
-//    @KafkaListener(topics = KafkaInitialConfiguration.sseTopic)
+    @KafkaListener(topics = KafkaInitialConfiguration.sseTopic)
     public void sseConnectionProcess(String msg, Acknowledgment ack) {
         log.info("get kafka msg from topic:{}, msg:{}", KafkaInitialConfiguration.sseTopic, msg);
         if (StrUtil.isEmpty(msg)) {
@@ -83,7 +83,7 @@ public class MessageConsumer {
         ack.acknowledge();
     }
 
-//    @KafkaListener(topicPattern = "sseTopic.*")
+    @KafkaListener(topicPattern = "sseTopic.*")
     public void sseConnectionProcess2(String msg, Acknowledgment ack) {
         log.info("get kafka2 msg from topic:{}, msg:{}", KafkaInitialConfiguration.sseTopic, msg);
         if (StrUtil.isEmpty(msg)) {