From d35a91690e79c8c8adb0fb4c2aead7420d2bba75 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 16b35e7..4b14f0e 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