package com.nisum.kafka_poc.service;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class KafkaConsumerService {

    @KafkaListener(topics = "test", groupId = "test-group")
    public void listen(String message) {
        System.out.println("Received message: " + message);
    }

}