X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;h=2cf263e9f1ec4d1f0afeec13676d090aa49890c1;hb=a6a0a22a5fa34a01b0e8b2bc1e0e2b82d7b60f33;hp=08c3955495a529ac465803b9fd5fac4025296b1b;hpb=60bc4a251dc9bab71d5ab5f12870147fec253ac9;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index 08c3955..2cf263e 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -19,32 +19,21 @@ import java.util.function.Consumer; public class ApplicationConfiguration { @Bean - public Consumer> consumer() - { - return (record) -> - { - // Handle record - }; - } - - @Bean - public EndlessConsumer endlessConsumer( + public EndlessConsumer endlessConsumer( KafkaConsumer kafkaConsumer, ExecutorService executor, - Consumer> handler, PartitionStatisticsRepository repository, ApplicationProperties properties) { return - new EndlessConsumer<>( + new EndlessConsumer( executor, repository, properties.getClientId(), properties.getTopic(), Clock.systemDefaultZone(), properties.getCommitInterval(), - kafkaConsumer, - handler); + kafkaConsumer); } @Bean