Package org.apache.kafka.common.test

Class KafkaClusterTestKit.Builder

java.lang.Object

org.apache.kafka.common.test.KafkaClusterTestKit.Builder

Enclosing class:

KafkaClusterTestKit

public static class KafkaClusterTestKit.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder(TestKitNodes nodes)

Method Summary

Modifier and Type	Method	Description
KafkaClusterTestKit	build()
String	getQuorumVotersConfig()
KafkaClusterTestKit.Builder	setConfigProp(String key, Object value)
KafkaClusterTestKit.Builder	setDeleteOnClose(boolean deleteOnClose)
KafkaClusterTestKit.Builder	setInitialVoterSet(Map<Integer,org.apache.kafka.common.Uuid> initialVoterSet)
KafkaClusterTestKit.Builder	setStandalone(boolean standalone)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Builder

public Builder(TestKitNodes nodes)

Method Details

setConfigProp

public KafkaClusterTestKit.Builder setConfigProp(String key,
 Object value)

setStandalone

public KafkaClusterTestKit.Builder setStandalone(boolean standalone)

setInitialVoterSet

public KafkaClusterTestKit.Builder setInitialVoterSet(Map<Integer,org.apache.kafka.common.Uuid> initialVoterSet)

getQuorumVotersConfig

public String getQuorumVotersConfig()
                             throws IOException

Throws:

IOException

setDeleteOnClose

public KafkaClusterTestKit.Builder setDeleteOnClose(boolean deleteOnClose)

build

public KafkaClusterTestKit build()
                          throws Exception

Throws:

Exception