private String id;
private long consumed = 0;
- @KafkaListener(
- id = "${spring.kafka.client-id}",
- groupId = "${spring.kafka.consumer.group-id}",
- topics = "${simple.consumer.topic}")
+ @KafkaListener(topics = "${simple.consumer.topic}")
private void handleRecord(
@Header(KafkaHeaders.RECEIVED_TOPIC)
String topic,