From c321a30b874072a96075440a297fab1369c23fe4 Mon Sep 17 00:00:00 2001 From: binarywoo27 Date: Wed, 17 Jan 2024 14:55:52 +0900 Subject: [PATCH] =?UTF-8?q?fix:=20=EB=B6=88=ED=95=84=EC=9A=94=ED=95=9C=20?= =?UTF-8?q?=EC=A0=95=EA=B8=B0=EA=B2=B0=EC=A0=9C=20KafkaConsumer=20?= =?UTF-8?q?=EC=82=AD=EC=A0=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kr/bb/payment/kafka/KafkaConsumer.java | 19 ------------------- 1 file changed, 19 deletions(-) delete mode 100644 src/main/java/kr/bb/payment/kafka/KafkaConsumer.java diff --git a/src/main/java/kr/bb/payment/kafka/KafkaConsumer.java b/src/main/java/kr/bb/payment/kafka/KafkaConsumer.java deleted file mode 100644 index 7490b12..0000000 --- a/src/main/java/kr/bb/payment/kafka/KafkaConsumer.java +++ /dev/null @@ -1,19 +0,0 @@ -package kr.bb.payment.kafka; - -import bloomingblooms.domain.batch.SubscriptionBatchDtoList; -import com.fasterxml.jackson.databind.ObjectMapper; -import kr.bb.payment.service.KakaopayService; -import lombok.RequiredArgsConstructor; -import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.stereotype.Component; - -@Component -@RequiredArgsConstructor -public class KafkaConsumer { - private final KakaopayService kakaopayService; - - @KafkaListener(topics = "subscription-batch", groupId = "payment-subscription") - public void subscriptionBatch(SubscriptionBatchDtoList subscriptionBatchDtoList) { - kakaopayService.renewSubscription(subscriptionBatchDtoList); - } -}