address comments

Author: lucliu1108

streams-integration-tests/src/test/java/io/confluent/kafka/streams/integration/TimestampedWindowStoreWithHeadersIntegrationTest.java

@@ -245,7 +245,7 @@ public void shouldPerformAllStoreOperationsWithHeaders() throws Exception {
             // Verify FETCH at t=8min for event-3 - should return event-3 from window 5-10min (count=50)
             assertEquals("event-3", results.get(idx).key().get("eventId").toString());
             assertEquals(50L, results.get(idx).value().get("count"));
-            assertSchemaIdHeaders(results.get(idx++), "FETCH t=5min");
+            assertSchemaIdHeaders(results.get(idx++), "FETCH t=8min");
 
             // Verify FETCH at t=10min for event-1 - should return event-1 from window 10-15min (count=60)
             assertEquals("event-1", results.get(idx).key().get("eventId").toString());