From beeb4f944823ab411560a640f83d792da133b6e6 Mon Sep 17 00:00:00 2001 From: ather1234 Date: Sun, 5 Jan 2025 12:54:16 -0800 Subject: [PATCH] Create TransactionListener --- .../midascore/listener/TransactionListener | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) create mode 100644 src/test/java/com/jpmc/midascore/listener/TransactionListener diff --git a/src/test/java/com/jpmc/midascore/listener/TransactionListener b/src/test/java/com/jpmc/midascore/listener/TransactionListener new file mode 100644 index 0000000..a0e2a16 --- /dev/null +++ b/src/test/java/com/jpmc/midascore/listener/TransactionListener @@ -0,0 +1,18 @@ +package com.jpmc.midascore.listener; + +import com.jpmc.midascore.model.Transaction; // Adjust import to match your Transaction class location +import org.springframework.kafka.annotation.KafkaListener; +import org.springframework.stereotype.Component; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@Component +public class TransactionListener { + + private static final Logger logger = LoggerFactory.getLogger(TransactionListener.class); + + @KafkaListener(topics = "${kafka.topic.name}", groupId = "midas-group") + public void listen(Transaction transaction) { + logger.info("Received transaction: {}", transaction); + } +}