cadonna commented on code in PR #13927:
URL: https://github.com/apache/kafka/pull/13927#discussion_r1254284586
##########
streams/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java:
##########
@@ -87,7 +88,7 @@ public static void closeCluster() {
}
- private final Time time = CLUSTER.time;
+ private final Time time = new MockTime(1);
Review Comment:
I tried to expose the `autoTickMs` parameter in embedded kafka, but I ran
into a infinite loop.
Regarding your question:
> Are we not worried that broker time and our time might diverge?
In almost all our integration tests broker time diverges from streams time
since the broker time does not advance but we usually use system time in
`KafkaStreams`. This is not something this PR introduces.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
