id = "${spring.kafka.client-id}",
idIsGroup = false,
topics = "${sumup.adder.topic}",
- batch = "true",
autoStartup = "false")
- public void accept(List<ConsumerRecord<K, V>> records)
+ public void accept(ConsumerRecord<K, V> record)
{
- // Do something with the data...
- log.info("{} - Received {} messages", id, records.size());
- for (ConsumerRecord<K, V> record : records)
- {
log.info(
"{} - {}: {}/{} - {}={}",
id,
recordHandler.accept(record);
consumed++;
- }
}
public void start()