1 package de.juplo.kafka;
3 import org.apache.kafka.clients.producer.KafkaProducer;
4 import org.apache.kafka.clients.producer.Producer;
5 import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
6 import org.springframework.boot.context.properties.EnableConfigurationProperties;
7 import org.springframework.context.annotation.Bean;
8 import org.springframework.context.annotation.Configuration;
9 import org.springframework.kafka.annotation.EnableKafka;
10 import org.springframework.kafka.core.ProducerFactory;
12 import java.util.Properties;
16 @EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class })
18 public class ApplicationConfiguration
21 public RestGateway restGateway(
22 ApplicationProperties applicationProperties,
23 KafkaProperties kafkaProperties,
24 Producer<String, Integer> kafkaProducer)
28 kafkaProperties.getClientId(),
29 applicationProperties.getTopic(),
30 applicationProperties.getPartition(),
34 @Bean(destroyMethod = "close")
35 public Producer<String, Integer> kafkaProducer(ProducerFactory<String, Integer> factory)
37 return factory.createProducer();