fix incorrect test setup

mjsax · mjsax · commit d3678b98a3dd · 2026-04-03T12:58:49.000-07:00
diff --git a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TimestampedWindowStoreWithHeadersTest.java b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TimestampedWindowStoreWithHeadersTest.java
@@ -199,7 +199,7 @@ public void shouldSetChangelogTopicProperties() throws Exception {
         // verify changelog topic properties
         final String changelogTopic = props.getProperty(StreamsConfig.APPLICATION_ID_CONFIG) + "-" + STORE_NAME + "-changelog";
         final Properties changelogTopicConfig = CLUSTER.getLogConfig(changelogTopic);
-        assertEquals("compact", changelogTopicConfig.getProperty("cleanup.policy"));
+        assertEquals("compact,delete", changelogTopicConfig.getProperty("cleanup.policy"));
     }
 
     @Test

Original file line number	Diff line number	Diff line change
`@@ -199,7 +199,7 @@ public void shouldSetChangelogTopicProperties() throws Exception {`
`199`	`199`	`// verify changelog topic properties`
`200`	`200`	`final String changelogTopic = props.getProperty(StreamsConfig.APPLICATION_ID_CONFIG) + "-" + STORE_NAME + "-changelog";`
`201`	`201`	`final Properties changelogTopicConfig = CLUSTER.getLogConfig(changelogTopic);`
`202`		`- assertEquals("compact", changelogTopicConfig.getProperty("cleanup.policy"));`
	`202`	`+ assertEquals("compact,delete", changelogTopicConfig.getProperty("cleanup.policy"));`
`203`	`203`	`}`
`204`	`204`
`205`	`205`	`@Test`