From e6b4f984fdd50c24485337d0fd335233b9f0e299 Mon Sep 17 00:00:00 2001 From: Kai Moritz 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 e4d9697..eaa9566 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