X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;h=ca8d1dbe2d5589b4c8a2630b3b6c61ce4466d8fe;hb=6e27677f9270811f37f0bd7d083fc8fb269e5f63;hp=eaa95666ba81bb229697519d38583d4ec42533d0;hpb=e6b4f984fdd50c24485337d0fd335233b9f0e299;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java
index eaa9566..ca8d1db 100644
--- 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[]