From eb6d41359a8957c6355275f7697db202d6a523db Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Fri, 11 Aug 2023 14:29:55 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into cjl --- screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java b/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java index 50f3a47..5f392d9 100644 --- a/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java +++ b/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java @@ -31,9 +31,9 @@ * ������������������������ * */ -//@Component +@Component @Slf4j -public class CruiserDataConsumer implements ConsumerSeekAware { +public class CruiserDataConsumer implements ConsumerSeekAware { @KafkaListener(topics = KafkaConstants.CRUISER_TOPIC_SECOND, containerFactory = "cruiserDataListenerFactory") public void listenSecondSpecial(ConsumerRecord<String, String> record) throws Exception { -- Gitblit v1.8.0