private String id;
private long consumed = 0;
- @KafkaListener(
- id = "${spring.kafka.client-id}",
- groupId = "${spring.kafka.consumer.group-id}",
- topics = "${simple.consumer.topic}")
private void handleRecord(
- @Header(KafkaHeaders.RECEIVED_TOPIC)
String topic,
- @Header(KafkaHeaders.RECEIVED_PARTITION_ID)
Integer partition,
- @Header(KafkaHeaders.OFFSET)
Long offset,
- @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY)
String key,
- @Payload
String value)
{
consumed++;