X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplication.java;h=376c4d3e7376a1ca28051e64df04391fd7811da1;hb=38ba36a057b701fa4cf553f9adbcb2af9950c35b;hp=04036d88cdff58ceef3058258512e4bb3f9ff31e;hpb=fc203aa408edc9d71f91e555a263c8a959b8a8d9;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java index 04036d8..376c4d3 100644 --- a/src/main/java/de/juplo/kafka/Application.java +++ b/src/main/java/de/juplo/kafka/Application.java @@ -7,8 +7,6 @@ import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.context.annotation.Bean; -import org.springframework.kafka.core.ConsumerFactory; import javax.annotation.PreDestroy; import java.util.concurrent.ExecutionException;