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)

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)

getQuorumVotersConfig

public String getQuorumVotersConfig()
                             throws IOException

Throws:

IOException

setDeleteOnClose

public KafkaClusterTestKit.Builder setDeleteOnClose(boolean deleteOnClose)

build

public KafkaClusterTestKit build()
                          throws Exception

Throws:

Exception