From 12492328e3d5e2e52d4ecb37cea18d86e29292db Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Thu, 26 Dec 2024 11:44:35 +0100 Subject: [PATCH] =?utf8?q?Der=20Offset=20eines=20inaktiven=20`BackOffState?= =?utf8?q?`=20sollte=20ein=20ung=C3=BCltiger=20Wert=20sein?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index 16b35e7c..4b14f0e6 100644 --- a/src/main/java/de/juplo/kafka/ExampleConsumer.java +++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java @@ -264,7 +264,7 @@ public class ExampleConsumer implements ConsumerRebalanceListener, Runnable BackOffState() { topicPartition = null; - offset = 0; + offset = -1; startTime = null; } -- 2.20.1