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);
+    }
+}