Added debug log for tracking event store delete operations (#111)

avinashkolluru · web-flow · commit 060ebf3bacca · 2025-08-16T11:36:42.000+05:30
* Added debug log for tracking event store delete operations

* minor fix
diff --git a/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/punctuators/AbstractThrottledPunctuator.java b/kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/punctuators/AbstractThrottledPunctuator.java
@@ -135,6 +135,7 @@ public final void punctuate(long timestamp) {
           } else {
             // can directly delete key from store
             eventStore.delete(windowMs);
+            log.debug("Deleted empty window for ts: {}", windowMs);
           }
         } else {
           ArrayList<T> windowTasks = new ArrayList<>(events.subList(i, events.size()));

Original file line number	Diff line number	Diff line change
`@@ -135,6 +135,7 @@ public final void punctuate(long timestamp) {`
`135`	`135`	`} else {`
`136`	`136`	`// can directly delete key from store`
`137`	`137`	`eventStore.delete(windowMs);`
	`138`	`+ log.debug("Deleted empty window for ts: {}", windowMs);`
`138`	`139`	`}`
`139`	`140`	`} else {`
`140`	`141`	`ArrayList<T> windowTasks = new ArrayList<>(events.subList(i, events.size()));`