From 1f65fd011582ac6587d60475315d2ee6662d9d5b Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Fri, 08 Sep 2023 09:01:39 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/wb' into qa --- screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java | 13 ++++++++++--- 1 files changed, 10 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..32c1fe2 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 @@ -1,3 +1,4 @@ +/* package com.moral.api.exception.consumer; @@ -27,13 +28,18 @@ import com.moral.constant.KafkaConstants; +*/ /* * ������������������������ - * */ + * +*//* -//@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 { @@ -118,3 +124,4 @@ } } +*/ -- Gitblit v1.8.0