Package org.apache.kafka.common.test.api

Class ClusterConfig.Builder

java.lang.Object

org.apache.kafka.common.test.api.ClusterConfig.Builder

Enclosing class:

ClusterConfig

public static class ClusterConfig.Builder
extends Object

Method Summary

Modifier and Type	Method	Description
ClusterConfig	build()
ClusterConfig.Builder	setAdminClientProperties(Map<String,String> adminClientProperties)
ClusterConfig.Builder	setAutoStart(boolean autoStart)
ClusterConfig.Builder	setBrokerListenerName(org.apache.kafka.common.network.ListenerName listenerName)
ClusterConfig.Builder	setBrokers(int brokers)
ClusterConfig.Builder	setBrokerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
ClusterConfig.Builder	setConsumerProperties(Map<String,String> consumerProperties)
ClusterConfig.Builder	setControllerListenerName(org.apache.kafka.common.network.ListenerName listenerName)
ClusterConfig.Builder	setControllers(int controllers)
ClusterConfig.Builder	setControllerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol)
ClusterConfig.Builder	setDisksPerBroker(int disksPerBroker)
ClusterConfig.Builder	setFeatures(Map<org.apache.kafka.server.common.Feature,Short> features)
ClusterConfig.Builder	setFirstBrokerId(Integer firstBrokerId)
ClusterConfig.Builder	setMetadataVersion(org.apache.kafka.server.common.MetadataVersion metadataVersion)
ClusterConfig.Builder	setPerServerProperties(Map<Integer,Map<String,String>> perServerProperties)
ClusterConfig.Builder	setProducerProperties(Map<String,String> producerProperties)
ClusterConfig.Builder	setSaslClientProperties(Map<String,String> saslClientProperties)
ClusterConfig.Builder	setSaslServerProperties(Map<String,String> saslServerProperties)
ClusterConfig.Builder	setServerProperties(Map<String,String> serverProperties)
ClusterConfig.Builder	setTags(List<String> tags)
ClusterConfig.Builder	setTrustStoreFile(File trustStoreFile)
ClusterConfig.Builder	setTypes(Set<Type> types)

Methods inherited from class java.lang.Object

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

Method Details

setTypes

public ClusterConfig.Builder setTypes(Set<Type> types)

setBrokers

public ClusterConfig.Builder setBrokers(int brokers)

setControllers

public ClusterConfig.Builder setControllers(int controllers)

setDisksPerBroker

public ClusterConfig.Builder setDisksPerBroker(int disksPerBroker)

setFirstBrokerId

public ClusterConfig.Builder setFirstBrokerId(Integer firstBrokerId)

setAutoStart

public ClusterConfig.Builder setAutoStart(boolean autoStart)

setBrokerSecurityProtocol

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

setBrokerListenerName

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

setControllerSecurityProtocol

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

setControllerListenerName

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

setTrustStoreFile

public ClusterConfig.Builder setTrustStoreFile(File trustStoreFile)

setMetadataVersion

public ClusterConfig.Builder setMetadataVersion(org.apache.kafka.server.common.MetadataVersion metadataVersion)

setServerProperties

public ClusterConfig.Builder setServerProperties(Map<String,String> serverProperties)

setConsumerProperties

public ClusterConfig.Builder setConsumerProperties(Map<String,String> consumerProperties)

setProducerProperties

public ClusterConfig.Builder setProducerProperties(Map<String,String> producerProperties)

setAdminClientProperties

public ClusterConfig.Builder setAdminClientProperties(Map<String,String> adminClientProperties)

setSaslServerProperties

public ClusterConfig.Builder setSaslServerProperties(Map<String,String> saslServerProperties)

setSaslClientProperties

public ClusterConfig.Builder setSaslClientProperties(Map<String,String> saslClientProperties)

setPerServerProperties

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

setTags

public ClusterConfig.Builder setTags(List<String> tags)

setFeatures

public ClusterConfig.Builder setFeatures(Map<org.apache.kafka.server.common.Feature,Short> features)

build

public ClusterConfig build()