From: Kai Moritz <kai@juplo.de>
Date: Sat, 3 Sep 2022 06:26:25 +0000 (+0200)
Subject: Log-Meldungen in ApplicationRebalanceListener angeglichen
X-Git-Tag: sumup-adder---lvm-2-tage~2
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;ds=sidebyside;h=348477f6e4ff77e78bf7b6db66e4716663c9512d;p=demos%2Fkafka%2Ftraining

Log-Meldungen in ApplicationRebalanceListener angeglichen
---

diff --git a/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java b/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
index a751e75..8e8464f 100644
--- a/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
+++ b/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
@@ -97,7 +97,7 @@ public class ApplicationRebalanceListener implements RebalanceListener
       }
       else
       {
-        log.info("Offset commits are disabled! Last commit: {}", lastCommit);
+        log.info("{} - Offset commits are disabled! Last commit: {}", id, lastCommit);
       }
     });
   }
@@ -108,13 +108,13 @@ public class ApplicationRebalanceListener implements RebalanceListener
   {
     if (!commitsEnabled)
     {
-      log.info("Offset commits are disabled! Last commit: {}", lastCommit);
+      log.info("{} - Offset commits are disabled! Last commit: {}", id, lastCommit);
       return;
     }
 
     if (lastCommit.plus(commitInterval).isBefore(clock.instant()))
     {
-      log.debug("Storing data and offsets, last commit: {}", lastCommit);
+      log.debug("{} - Storing data and offsets, last commit: {}", id, lastCommit);
       partitions.forEach(partition -> stateRepository.save(
           new StateDocument(
               partition,