git.gumartinm.name Git - JavaForFun/blob

   1 package de.example.spring.kafka;
   2
   3 import org.slf4j.Logger;
   4 import org.slf4j.LoggerFactory;
   5 import org.springframework.kafka.annotation.KafkaListener;
   6
   7 public class Receiver {
   8
   9   private static final Logger LOGGER = LoggerFactory.getLogger(Receiver.class);
  10
  11   @KafkaListener(topics = "test")
  12   public void receiveMessage(String message) {
  13     LOGGER.info("received message='{}'", message);
  14   }
  15
  16 }