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

Class ClusterConfig

java.lang.Object
org.apache.kafka.common.test.api.ClusterConfig
public class ClusterConfig extends Object
Represents an immutable requested configuration of a Kafka cluster for integration testing.

  • Method Details

    • clusterTypes

      public Set<Type> clusterTypes()

    • firstBrokerId

      public Integer firstBrokerId()

    • numBrokers

      public int numBrokers()

    • numControllers

      public int numControllers()

    • numDisksPerBroker

      public int numDisksPerBroker()

    • isAutoStart

      public boolean isAutoStart()

    • serverProperties

      public Map<String,String> serverProperties()

    • producerProperties

      public Map<String,String> producerProperties()

    • consumerProperties

      public Map<String,String> consumerProperties()

    • adminClientProperties

      public Map<String,String> adminClientProperties()

    • saslServerProperties

      public Map<String,String> saslServerProperties()

    • saslClientProperties

      public Map<String,String> saslClientProperties()

    • brokerSecurityProtocol

      public org.apache.kafka.common.security.auth.SecurityProtocol brokerSecurityProtocol()

    • controllerListenerName

      public org.apache.kafka.common.network.ListenerName controllerListenerName()

    • controllerSecurityProtocol

      public org.apache.kafka.common.security.auth.SecurityProtocol controllerSecurityProtocol()

    • brokerListenerName

      public org.apache.kafka.common.network.ListenerName brokerListenerName()

    • trustStoreFile

      public Optional<File> trustStoreFile()

    • metadataVersion

      public org.apache.kafka.server.common.MetadataVersion metadataVersion()

    • perServerOverrideProperties

      public Map<Integer,Map<String,String>> perServerOverrideProperties()

    • tags

      public List<String> tags()

    • equals

      public boolean equals(Object object)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • copyOf

      public ClusterConfig copyOf()

    • copyOf

      public ClusterConfig copyOf(Consumer<ClusterConfig.Builder> builderConsumer)

    • features

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

    • displayTags

      public Set<String> displayTags()

    • defaultBuilder

      public static ClusterConfig.Builder defaultBuilder()

    • builder

      public static ClusterConfig.Builder builder()

    • builder

      public static ClusterConfig.Builder builder(ClusterConfig clusterConfig)