-package de.juplo.kafka;
-
-import org.apache.kafka.clients.consumer.Consumer;
-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.core.ConsumerFactory;
-
-
-@Configuration
-@EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class })
-public class ApplicationConfiguration
-{
- @Bean
- public SimpleConsumer simpleConsumer(
- Consumer<String, String> kafkaConsumer,
- KafkaProperties kafkaProperties,
- ApplicationProperties applicationProperties)
- {
- return
- new SimpleConsumer(
- kafkaProperties.getClientId(),
- applicationProperties.getTopic(),
- kafkaConsumer);
- }
-
- @Bean
- public Consumer<?, ?> kafkaConsumer(ConsumerFactory<?, ?> factory)
- {
- return factory.createConsumer();
- }
-}