[KAFKA-13648] KRaft ClusterInstance does not allow for deferred start

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: unit tests
• Assignee: Unassigned
• Reporter: David Arthur
• Created: 07/Feb/22 19:55
• Updated: 27/Sep/22 11:14

Description

In our JUnit testkit extension, we allow for a cluster to be started explicitly in the test by annotating a test with AutoStart.NO. This allows for additional configuration or setup to be done in the test method before starting the cluster. For example:

@ClusterTest(clusterType = Type.ZK, brokers = 3, autoStart = AutoStart.NO)
public void testSomething(ClusterInstance clusterInstance) {
    clusterInstance.config().serverProperties().put("foo", "bar")
    clusterInstance.start();
    // ...
}

This works fine for ZK clusters, but is broken for KRaft clusters.

Issue Links

• blocks: KAFKA-12617 Convert MetadataRequestTest to use ClusterTest
• links to: GitHub Pull Request #12400