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;
7 import org.springframework.kafka.listener.CommonContainerStoppingErrorHandler;
9 import java.util.function.Consumer;
13 @EnableConfigurationProperties(ApplicationProperties.class)
14 public class ApplicationConfiguration
17 public Consumer<ConsumerRecord<String, Long>> consumer()
26 public CommonContainerStoppingErrorHandler errorHandler()
28 return new CommonContainerStoppingErrorHandler();