In einer @SpringBootApplication wird @EnableKafka nicht benötigt

* In einer reinen Spring-Anwendung wird @EnableKafka benötigit, damit
  mit @KafkaListener annotierte Methoden/Klassen von Spring aufgegriffen
  werden.
* In einer @SpringBootApplication konfiguriert die Autokonfiguration von
  Spring Boot Kafka automatisch, sobald die ensprechenden Klassen auf dem
  Classpath gefunden werden.

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 26fd90a..a72431e 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -3,12 +3,10 @@ package de.juplo.kafka;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.kafka.annotation.EnableKafka;
 import org.springframework.kafka.annotation.KafkaListener;
 
 // tag::supersimple[]
 @SpringBootApplication
-@EnableKafka
 @Slf4j
 public class Application
 {