Add better logging for indexer (#751)

Co-authored-by: Bryan Burkholder <[email protected]>
slackhq · Jan 22, 2024 · baa7262 · baa7262
1 parent fff30bb
commit baa7262
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/kaldb/src/main/java/com/slack/kaldb/server/KaldbIndexer.java b/kaldb/src/main/java/com/slack/kaldb/server/KaldbIndexer.java
@@ -120,7 +120,11 @@ private long indexerPreStart() throws Exception {
     // Close these stores since we don't need them after preStart.
     snapshotMetadataStore.close();
     recoveryTaskMetadataStore.close();
-    LOG.info("Completed Kaldb indexer pre start.");
+    LOG.info(
+        "Completed Kaldb indexer pre start - currentEndOffsetForPartition {}, currentBeginningOffsetForPartition {}, startOffset {}",
+        currentEndOffsetForPartition,
+        currentBeginningOffsetForPartition,
+        startOffset);
 
     return startOffset;
   }