THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
package org.apache.kafka.testkit;
public class TimeUtils {
/**
* Wait for condition to be met for at most {@code maxWaitMs} and throw assertion failure otherwise.
* This should be used instead of {@code Thread.sleep} whenever possible as it allows a longer timeout to be used
* without unnecessarily increasing test time (as the condition is checked frequently). The longer timeout is needed to
* avoid transient failures due to slow or overloaded machines.
*/
public static void waitForCondition(final BooleanSupplier testCondition, final long maxWaitMs, String conditionDetails) { ... }
}
|
| Code Block | ||||
|---|---|---|---|---|
| ||||
package org.apache.kafka.testkit;
public class SslConfigBuilder {
public static SslConfigBuilder server(Path trustStorePath) { ... }
public static SslConfigBuilder client(Path trustStorePath) { ... }
public SslConfigBuilder setHost(String host) { ... }
public SslConfigBuilder setCertificateAlias(String certificateAlias) { ... }
public Map<String, String> build() { ... }
}
|
Proposed Changes
We will introduce a new artifact called kafka-testkit that will contain the Java classes for the test library. This module will depend on the clients and core kafka artifacts, but it won't depend on any of the Kafka test artifacts. As such, users won't have our tests on their classpath.
...