1 package de.juplo.kafka;
3 import org.springframework.boot.SpringApplication;
4 import org.springframework.boot.autoconfigure.SpringBootApplication;
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.kafka.annotation.EnableKafka;
9 import org.springframework.kafka.core.KafkaTemplate;
12 @SpringBootApplication
13 @EnableConfigurationProperties({ KafkaProperties.class, ApplicationProperties.class })
15 public class Application
18 public RestGateway restGateway(
19 ApplicationProperties applicationProperties,
20 KafkaProperties kafkaProperties,
21 KafkaTemplate<String, Integer> kafkaTemplate)
25 kafkaProperties.getClientId(),
26 applicationProperties.getTopic(),
27 applicationProperties.getPartition(),
32 public static void main(String[] args)
34 SpringApplication.run(Application.class, args);