@Component
public class KafkaMessageListener {
private Logger LOG = LoggerFactory.getLogger(KafkaMessageListener.class)
@KafkaListener(topics = “test_topic”)
public void receiveMessage(String message) {
LOG.info("Received message: {}", message);
//Add custom metric here
}
}