From d59f4d418302b70bca9b807371c930a332f083f8 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 25 Feb 2024 10:32:20 +0100
Subject: [PATCH] WIP:loading

---
 .../kafka/chat/backend/implementation/kafka/DataChannel.java | 5 +++++
 1 file changed, 5 insertions(+)

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];
         });
   }
-- 
2.20.1