@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[]