From 72a6d5a954312a8a53e5bdd18c5f8f8b57b54dbc Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Wed, 08 Nov 2023 14:40:58 +0800 Subject: [PATCH] chore:分享权限修改提交 --- screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java | 9 ++++++--- 1 files changed, 6 insertions(+), 3 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..8ebcc3d 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 @@ -29,11 +29,14 @@ /* * ������������������������ - * */ + * +*/ -//@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