diff --git a/test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/junit/ClusterTestExtensions.java b/test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/junit/ClusterTestExtensions.java index f08abdb32aa..c827ef0ab3c 100644 --- a/test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/junit/ClusterTestExtensions.java +++ b/test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/junit/ClusterTestExtensions.java @@ -78,14 +78,14 @@ import static org.junit.jupiter.api.Assertions.assertTrue; * *
  * class SomeIntegrationTest {
- *   @ClusterTest(brokers = 1, controllers = 1, clusterType = ClusterType.Both)
- *   def someTest(): Unit = {
+ *   @ClusterTest(brokers = 1, controllers = 1, types = {Type.KRAFT, Type.CO_KRAFT})
+ *   void someTest(ClusterInstance cluster) {
  *     assertTrue(condition)
  *   }
  * }
  * 
* - * will generate two invocations of "someTest" (since ClusterType.Both was given). For each invocation, the test class + * will generate two invocations of "someTest" (since two cluster types were specified). For each invocation, the test class * SomeIntegrationTest will be instantiated, lifecycle methods (before/after) will be run, and "someTest" will be invoked. * * A special system property "kafka.cluster.test.repeat" can be used to cause repeated invocation of the tests.