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 index 640ab79..c3429f9 100644 --- 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 windowTasks = new ArrayList<>(events.subList(i, events.size()));