Package org.apache.kafka.common.test

Class TestKitNodes.Builder

java.lang.Object

org.apache.kafka.common.test.TestKitNodes.Builder

Enclosing class:

TestKitNodes

public static class TestKitNodes.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(org.apache.kafka.metadata.bootstrap.BootstrapMetadata bootstrapMetadata)

Method Summary

Modifier and Type	Method	Description
TestKitNodes	build()
TestKitNodes.Builder	setBaseDirectory(Path baseDirectory)
TestKitNodes.Builder	setBootstrapMetadata(org.apache.kafka.metadata.bootstrap.BootstrapMetadata bootstrapMetadata)
TestKitNodes.Builder	setBootstrapMetadataVersion(org.apache.kafka.server.common.MetadataVersion metadataVersion)
TestKitNodes.Builder	setBrokerListenerName(org.apache.kafka.common.network.ListenerName listenerName)
TestKitNodes.Builder	setBrokerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
TestKitNodes.Builder	setClusterId(String clusterId)
TestKitNodes.Builder	setCombined(boolean combined)
TestKitNodes.Builder	setControllerListenerName(org.apache.kafka.common.network.ListenerName listenerName)
TestKitNodes.Builder	setControllerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
TestKitNodes.Builder	setFeature(String featureName, short level)
TestKitNodes.Builder	setNumBrokerNodes(int numBrokerNodes)
TestKitNodes.Builder	setNumControllerNodes(int numControllerNodes)
TestKitNodes.Builder	setNumDisksPerBroker(int numDisksPerBroker)
TestKitNodes.Builder	setPerServerProperties(Map<Integer,Map<String,String>> perServerProperties)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Builder

public Builder(org.apache.kafka.metadata.bootstrap.BootstrapMetadata bootstrapMetadata)

Method Details

setClusterId

public TestKitNodes.Builder setClusterId(String clusterId)

setBootstrapMetadataVersion

public TestKitNodes.Builder setBootstrapMetadataVersion(org.apache.kafka.server.common.MetadataVersion metadataVersion)

setBootstrapMetadata

public TestKitNodes.Builder setBootstrapMetadata(org.apache.kafka.metadata.bootstrap.BootstrapMetadata bootstrapMetadata)

setFeature

public TestKitNodes.Builder setFeature(String featureName,
 short level)

setCombined

public TestKitNodes.Builder setCombined(boolean combined)

setNumControllerNodes

public TestKitNodes.Builder setNumControllerNodes(int numControllerNodes)

setNumBrokerNodes

public TestKitNodes.Builder setNumBrokerNodes(int numBrokerNodes)

setNumDisksPerBroker

public TestKitNodes.Builder setNumDisksPerBroker(int numDisksPerBroker)

setPerServerProperties

public TestKitNodes.Builder setPerServerProperties(Map<Integer,Map<String,String>> perServerProperties)

setBaseDirectory

public TestKitNodes.Builder setBaseDirectory(Path baseDirectory)

setBrokerListenerName

public TestKitNodes.Builder setBrokerListenerName(org.apache.kafka.common.network.ListenerName listenerName)

setBrokerSecurityProtocol

public TestKitNodes.Builder setBrokerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)

setControllerListenerName

public TestKitNodes.Builder setControllerListenerName(org.apache.kafka.common.network.ListenerName listenerName)

setControllerSecurityProtocol

public TestKitNodes.Builder setControllerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)

build

public TestKitNodes build()