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 2287a33..397b35a 100644 (file)
--- 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];
         });
   }