From e6b4f984fdd50c24485337d0fd335233b9f0e299 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 1 Aug 2022 22:57:08 +0200
Subject: [PATCH] Fehlerchen in Logmeldung korrigiert
---
src/main/java/de/juplo/kafka/SimpleConsumer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java
index e4d96974..eaa95666 100644
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -92,7 +92,7 @@ public class SimpleConsumer
{
log.info("{} - Closing the KafkaConsumer", id);
consumer.close();
- log.info("C - DONE!");
+ log.info("{} - DONE!");
stopped.signal();
}
finally
--
2.20.1