From: Kai Moritz Date: Tue, 23 May 2023 19:21:25 +0000 (+0200) Subject: Hinweis auf Offset-Commit entfernt X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=6e27677f9270811f37f0bd7d083fc8fb269e5f63;p=demos%2Fkafka%2Ftraining Hinweis auf Offset-Commit entfernt --- 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[]