juplo.de Git - demos/kafka/training/blob - src/main/java/de/juplo/kafka/SimpleConsumer.java

   1 package de.juplo.kafka;
   2
   3 import lombok.extern.slf4j.Slf4j;
   4 import org.springframework.beans.factory.annotation.Value;
   5 import org.springframework.kafka.annotation.KafkaListener;
   6 import org.springframework.kafka.support.KafkaHeaders;
   7 import org.springframework.messaging.handler.annotation.Header;
   8 import org.springframework.messaging.handler.annotation.Payload;
   9 import org.springframework.stereotype.Component;
  10
  11
  12 @Slf4j
  13 @Component
  14 public class SimpleConsumer
  15 {
  16   @Value("${spring.kafka.client-id}")
  17   private String id;
  18   private long consumed = 0;
  19
  20   private void handleRecord(
  21     String topic,
  22     Integer partition,
  23     Long offset,
  24     String key,
  25     String value)
  26   {
  27     consumed++;
  28     log.info("{} - {}: {}/{} - {}={}", id, offset, topic, partition, key, value);
  29   }
  30 }