1 package de.juplo.kafka;
3 import org.apache.kafka.clients.consumer.Consumer;
4 import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
5 import org.springframework.boot.context.properties.EnableConfigurationProperties;
6 import org.springframework.context.annotation.Bean;
7 import org.springframework.context.annotation.Configuration;
9 import org.springframework.kafka.core.ConsumerFactory;
13 @EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class })
14 public class ApplicationConfiguration
17 public SimpleConsumer simpleConsumer(
18 Consumer<String, String> kafkaConsumer,
19 KafkaProperties kafkaProperties,
20 ApplicationProperties applicationProperties)
24 kafkaProperties.getClientId(),
25 applicationProperties.getTopic(),
30 public Consumer<?, ?> kafkaConsumer(ConsumerFactory<?, ?> factory)
32 return factory.createConsumer();