Package org.apache.kafka.common.test.api
Class ClusterConfig.Builder
java.lang.Object
org.apache.kafka.common.test.api.ClusterConfig.Builder
- Enclosing class:
ClusterConfig
-
Method Summary
Modifier and TypeMethodDescriptionbuild()setAdminClientProperties(Map<String, String> adminClientProperties) setAutoStart(boolean autoStart) setBrokerListenerName(org.apache.kafka.common.network.ListenerName listenerName) setBrokers(int brokers) setBrokerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol) setConsumerProperties(Map<String, String> consumerProperties) setControllerListenerName(org.apache.kafka.common.network.ListenerName listenerName) setControllers(int controllers) setControllerSecurityProtocol(org.apache.kafka.common.security.auth.SecurityProtocol securityProtocol) setDisksPerBroker(int disksPerBroker) setFeatures(Map<org.apache.kafka.server.common.Feature, Short> features) setFirstBrokerId(Integer firstBrokerId) setMetadataVersion(org.apache.kafka.server.common.MetadataVersion metadataVersion) setProducerProperties(Map<String, String> producerProperties) setSaslClientProperties(Map<String, String> saslClientProperties) setSaslServerProperties(Map<String, String> saslServerProperties) setServerProperties(Map<String, String> serverProperties) setTrustStoreFile(File trustStoreFile)
-
Method Details
-
setTypes
-
setBrokers
-
setControllers
-
setDisksPerBroker
-
setFirstBrokerId
-
setAutoStart
-
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
-
setMetadataVersion
public ClusterConfig.Builder setMetadataVersion(org.apache.kafka.server.common.MetadataVersion metadataVersion) -
setServerProperties
-
setConsumerProperties
-
setProducerProperties
-
setAdminClientProperties
-
setSaslServerProperties
-
setSaslClientProperties
-
setPerServerProperties
-
setTags
-
setFeatures
public ClusterConfig.Builder setFeatures(Map<org.apache.kafka.server.common.Feature, Short> features) -
build
-