From 2903ac29c76fcb43e62f1dad365f2e5c2c9ffb2d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=87=E4=BD=B3?= Date: Wed, 15 Sep 2021 16:16:43 +0800 Subject: [PATCH] =?UTF-8?q?EmailJobsListener=E6=B3=A8=E9=87=8AKafkaListene?= =?UTF-8?q?r=E6=B3=A8=E8=A7=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../executor/service/jobhandler/EmailJobsListener.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/executor/src/main/java/cn/org/gitlink/notification/executor/service/jobhandler/EmailJobsListener.java b/executor/src/main/java/cn/org/gitlink/notification/executor/service/jobhandler/EmailJobsListener.java index 24e0e2f..c9eda84 100644 --- a/executor/src/main/java/cn/org/gitlink/notification/executor/service/jobhandler/EmailJobsListener.java +++ b/executor/src/main/java/cn/org/gitlink/notification/executor/service/jobhandler/EmailJobsListener.java @@ -14,7 +14,7 @@ import org.springframework.stereotype.Component; @Component @Configuration //todo 邮件的topics和groupId待处理 -@KafkaListener(topics = "${spring.kafka.consumer.topic}", groupId = "${spring.kafka.consumer.group_id}") +//@KafkaListener(topics = "${spring.kafka.consumer.topic}", groupId = "${spring.kafka.consumer.group_id}") public class EmailJobsListener { private Logger logger = LogManager.getLogger(EmailJobsListener.class);