Korrekturen & Verbesserungen aus producer-supersimple übernommen

[demos/kafka/training] / src / main / java / de / juplo / kafka / Application.java

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index a0b96c2..4632e22 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -23,7 +23,6 @@ public class Application implements ApplicationRunner
   {
     for (int i = 0; true; i++)
     {
-      // tag::callback[]
       ListenableFuture<SendResult<String, String>> listenableFuture =
           kafkaTemplate.send("test", Long.toString(i%10), Long.toString(i));
 
@@ -35,7 +34,6 @@ public class Application implements ApplicationRunner
               result.getRecordMetadata().partition(),
               result.getRecordMetadata().offset()),
           e -> log.error("ERROR sendig message", e));
-      // end::callback[]
 
       try
       {