From: Kai Moritz <kai@juplo.de>
Date: Sun, 25 Feb 2024 09:32:20 +0000 (+0100)
Subject: WIP:loading
X-Git-Tag: rebase--2024-02-26--19-46~7
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=d59f4d418302b70bca9b807371c930a332f083f8;p=demos%2Fkafka%2Fchat

WIP:loading
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
index 2287a337..397b35af 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
@@ -204,6 +204,10 @@ public class DataChannel implements Runnable, ConsumerRebalanceListener
             log.info("Resuming normal operations...");
             loadInProgress = false;
           }
+          else
+          {
+            log.info("{} messages loaded. Loading of messages still in proress...", records.count());
+          }
         }
         else
         {
@@ -287,6 +291,7 @@ public class DataChannel implements Runnable, ConsumerRebalanceListener
         {
           TopicPartition partition = new TopicPartition(topic, shard);
           long position = consumer.position(partition);
+          log.info("{}: position={}, current={}", partition, position, currentOffset[shard]);
           return position >= currentOffset[shard];
         });
   }