X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;h=0000000000000000000000000000000000000000;hb=68d951b20012882c0584dfa1179c0488a4f054b6;hp=59652c086d6df66ae8adfa7b06199cda46b4ca27;hpb=7e38c678f43c975f2a58391bb32e1d044278e237;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java deleted file mode 100644 index 59652c0..0000000 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ /dev/null @@ -1,29 +0,0 @@ -package de.juplo.kafka; - -import org.springframework.boot.autoconfigure.kafka.KafkaProperties; -import org.springframework.boot.context.properties.EnableConfigurationProperties; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; -import org.springframework.kafka.annotation.EnableKafka; -import org.springframework.kafka.core.KafkaTemplate; - - -@Configuration -@EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class }) -@EnableKafka -public class ApplicationConfiguration -{ - @Bean - public RestGateway restGateway( - ApplicationProperties applicationProperties, - KafkaProperties kafkaProperties, - KafkaTemplate kafkaTemplate) - { - return - new RestGateway( - kafkaProperties.getClientId(), - applicationProperties.getTopic(), - applicationProperties.getPartition(), - kafkaTemplate); - } -}