From 18e1fe58c9385d093bdf09769e5f1f19b2b740f1 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 2 Nov 2024 22:02:13 +0100
Subject: [PATCH] WIP

---
 src/main/java/de/juplo/kafka/ExampleConsumer.java | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index b60ec37..0fbddc8 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -168,11 +168,6 @@ public class ExampleConsumer implements Runnable, ConsumerRebalanceListener
       consumer.close();
       log.info("{}: Consumed {} messages in total, exiting!", id, consumed);
     }
-
-    log.info("{} - Final commit for transaction", id);
-    producer.commitTransaction();
-    log.info("{} - Closing the producer", id);
-    producer.close();
   }
 
   private void commitIfNecessary()
-- 
2.20.1