Class TestKitNodes.Builder

java.lang.Object
org.apache.kafka.common.test.TestKitNodes.Builder
Enclosing class:
TestKitNodes
public static class TestKitNodes.Builder extends Object

  • 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)

    • 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()