divijvaidya commented on PR #18106:
URL: https://github.com/apache/kafka/pull/18106#issuecomment-2580463968
I looked at the failing tests. The root cause is that the streams related
tests spin up a EmbeddedCluster . This cluster initializes time as "mockTime".
MockTime doesn't increment unless you manually increment it. But rest of the
test uses actual time by using Thread.Sleep. Hence cluster's time is behind the
actual time when test is executing.
They can be fixed with the following change:
```
- public static final EmbeddedKafkaCluster CLUSTER = new
EmbeddedKafkaCluster(NUM_BROKERS);
+ public static final EmbeddedKafkaCluster CLUSTER = new
EmbeddedKafkaCluster(
+ NUM_BROKERS,
+
Utils.mkProperties(Collections.singletonMap("log.message.timestamp.after.max.ms",
String.valueOf(Long.MAX_VALUE))));
```
--
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]
