Hinweis auf Offset-Commit entfernt

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

diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java
index eaa9566..ca8d1db 100644 (file)
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -29,7 +29,7 @@ public class SimpleConsumer
     // tag::create[]
     Properties props = new Properties();
     props.put("bootstrap.servers", ":9092");
-    props.put("group.id", "my-consumer"); // << Used for Offset-Commits
+    props.put("group.id", "my-consumer"); // << Used for Offset-Management
     // end::create[]
     props.put("auto.offset.reset", "earliest");
     // tag::create[]