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
{
- @KafkaListener(id = "supersimple", topics = "out")
+ @KafkaListener(id = "supersimple", topics = "test")
public void recieve(String message)
{
log.info("Recieved message: {}", message);
SpringApplication.run(Application.class, args);
}
}
-// end::supersimple[]
\ No newline at end of file
+// end::supersimple[]