1 package de.juplo.kafka;
3 import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
4 import org.springframework.boot.context.properties.EnableConfigurationProperties;
5 import org.springframework.context.annotation.Bean;
6 import org.springframework.context.annotation.Configuration;
7 import org.springframework.kafka.annotation.EnableKafka;
8 import org.springframework.kafka.core.KafkaTemplate;
12 @EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class })
14 public class ApplicationConfiguration
17 public RestGateway restGateway(
18 ApplicationProperties applicationProperties,
19 KafkaProperties kafkaProperties,
20 KafkaTemplate<String, Integer> kafkaTemplate)
24 kafkaProperties.getClientId(),
25 applicationProperties.getTopic(),
26 applicationProperties.getPartition(),