1 package de.juplo.kafka;
3 import org.apache.kafka.clients.consumer.ConsumerRecord;
4 import org.springframework.boot.context.properties.EnableConfigurationProperties;
5 import org.springframework.context.annotation.Bean;
6 import org.springframework.context.annotation.Configuration;
8 import java.util.function.Consumer;
12 @EnableConfigurationProperties(ApplicationProperties.class)
13 public class ApplicationConfiguration
16 public Consumer<ConsumerRecord<String, Long>> consumer()