From 3033e964839eaa1cbf38b5142f1d26e35c3f0343 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Thu, 26 Dec 2024 11:44:35 +0100
Subject: [PATCH] FIX:offset-for-no-offset

---
 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 21991f87..fe5403f8 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