From 1b033ad5addcbc48767522f30858f129a6f3919f Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Tue, 23 May 2023 21:46:05 +0200
Subject: [PATCH] Gewollten Fehler im Consumer von `first-contact` korrigiert
---
src/main/java/de/juplo/kafka/SimpleConsumer.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java
index ca8d1dbe..d8f36249 100644
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -79,7 +79,8 @@ public class SimpleConsumer
}
catch(WakeupException e)
{
- log.info("{} - RIIING!", id);
+ log.info("{} - Closing the KafkaConsumer", id);
+ consumer.close();
}
catch(Exception e)
{
@@ -87,11 +88,10 @@ public class SimpleConsumer
}
finally
{
+ log.info("{} - Shutting down...");
this.lock.lock();
try
{
- log.info("{} - Closing the KafkaConsumer", id);
- consumer.close();
log.info("{} - DONE!");
stopped.signal();
}
--
2.20.1