[beam-core] Add more logging when creating observers

datadrivencz · Mar 3, 2025 · 05ac176 · 05ac176
1 parent 0f2d91b
commit 05ac176
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/beam/core/src/main/java/cz/o2/proxima/beam/core/direct/io/CommitLogRead.java b/beam/core/src/main/java/cz/o2/proxima/beam/core/direct/io/CommitLogRead.java
@@ -461,6 +461,7 @@ private void startObserve(@Nullable String name, Partition partition, OffsetRang
         handle = observeBulkPartitions(name, restriction, reader, observer);
       }
       runningObserves.put(partition.getId(), handle);
+      log.info("Started observer for partition {}", partition);
     }
 
     abstract ObserveHandle observeBulkOffsets(
@@ -483,7 +484,10 @@ public void setup() {
               .<Integer, ObserveHandle>removalListener(
                   notification -> {
                     if (notification.wasEvicted()) {
-                      log.info("Closing observer {} due to expiry", notification.getKey());
+                      log.info(
+                          "Closing observer {} due to expiry {}",
+                          notification.getKey(),
+                          notification.getCause());
                       Optional.ofNullable(observers.remove(notification.getKey()))
                           .ifPresent(o -> o.stop(true));
                       notification.getValue().close();