1 package de.juplo.kafka;
3 import lombok.extern.slf4j.Slf4j;
4 import org.springframework.beans.factory.annotation.Autowired;
5 import org.springframework.beans.factory.annotation.Value;
6 import org.springframework.boot.ApplicationArguments;
7 import org.springframework.boot.ApplicationRunner;
8 import org.springframework.boot.SpringApplication;
9 import org.springframework.boot.autoconfigure.SpringBootApplication;
10 import org.springframework.kafka.config.KafkaListenerEndpointRegistry;
12 import javax.annotation.PreDestroy;
15 @SpringBootApplication
17 public class Application implements ApplicationRunner
20 KafkaListenerEndpointRegistry registry;
21 @Value("${consumer.client-id}")
26 public void run(ApplicationArguments args) throws Exception
28 log.info("Starting EndlessConsumer");
29 this.registry.getListenerContainer(clientId).start();
33 public void stopExecutor()
35 log.info("Stopping EndlessConsumer");
36 this.registry.getListenerContainer(clientId).stop();
40 public static void main(String[] args)
42 SpringApplication.run(Application.class, args);