From 6e27677f9270811f37f0bd7d083fc8fb269e5f63 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 23 May 2023 21:21:25 +0200 Subject: [PATCH] Hinweis auf Offset-Commit entfernt --- src/main/java/de/juplo/kafka/SimpleConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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[] -- 2.20.1