You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "David Arthur (Jira)" <ji...@apache.org> on 2022/02/07 19:56:00 UTC

[jira] [Created] (KAFKA-13648) KRaft ClusterInstance does not allow for deferred start

David Arthur created KAFKA-13648:
------------------------------------

             Summary: KRaft ClusterInstance does not allow for deferred start
                 Key: KAFKA-13648
                 URL: https://issues.apache.org/jira/browse/KAFKA-13648
             Project: Kafka
          Issue Type: Bug
          Components: unit tests
            Reporter: David Arthur


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:


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

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



--
This message was sent by Atlassian Jira
(v8.20.1#820001)