diff --git a/src/main/java/com/azure/cosmos/examples/changefeed/SampleChangeFeedEstimator.java b/src/main/java/com/azure/cosmos/examples/changefeed/SampleChangeFeedEstimator.java
index 3c56d14..d63cfa8 100644
--- a/src/main/java/com/azure/cosmos/examples/changefeed/SampleChangeFeedEstimator.java
+++ b/src/main/java/com/azure/cosmos/examples/changefeed/SampleChangeFeedEstimator.java
@@ -112,9 +112,9 @@ public static void main(String[] args) {
                     logger.error("This never needs to be called, as this is just monitoring the state");
                 })
                 .buildChangeFeedProcessor();
-
-            AtomicInteger totalLag = new AtomicInteger();
             // <EstimatedLag>
+            AtomicInteger totalLag = new AtomicInteger();
+            
             Mono<List<ChangeFeedProcessorState>> currentState = changeFeedProcessorMainInstance.getCurrentState();
             currentState.map(state -> {
                 for (ChangeFeedProcessorState changeFeedProcessorState : state) {