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.KafkaTemplate;
11 import org.springframework.kafka.core.ProducerFactory;
13 import java.util.Properties;
17 @EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class })
19 public class ApplicationConfiguration
22 public RestGateway restGateway(
23 ApplicationProperties applicationProperties,
24 KafkaProperties kafkaProperties,
25 KafkaTemplate<String, Integer> kafkaTemplate)
29 kafkaProperties.getClientId(),
30 applicationProperties.getPartition(),
34 @Bean(destroyMethod = "close")
35 public Producer<String, Integer> kafkaProducer(ProducerFactory<String, Integer> factory)
37 return factory.createProducer();