1 package de.juplo.kafka;
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;
14 public class SimpleConsumer
16 @Value("${spring.kafka.client-id}")
18 private long consumed = 0;
20 private void handleRecord(
28 log.info("{} - {}: {}/{} - {}={}", id, offset, topic, partition, key, value);