Annotation Interface ClusterTest

@Documented @Target(METHOD) @Retention(RUNTIME) @TestTemplate @Tag("integration") public @interface ClusterTest

  • Element Details

    • types

      Type[] types
      Default:
      {}

    • brokers

      int brokers
      Default:
      0

    • controllers

      int controllers
      Default:
      0

    • disksPerBroker

      int disksPerBroker
      Default:
      0

    • autoStart

      AutoStart autoStart
      Default:
      DEFAULT

    • brokerSecurityProtocol

      org.apache.kafka.common.security.auth.SecurityProtocol brokerSecurityProtocol
      Default:
      PLAINTEXT

    • brokerListener

      String brokerListener
      Default:
      "EXTERNAL"

    • controllerSecurityProtocol

      org.apache.kafka.common.security.auth.SecurityProtocol controllerSecurityProtocol
      Default:
      PLAINTEXT

    • controllerListener

      String controllerListener
      Default:
      "CONTROLLER"

    • metadataVersion

      org.apache.kafka.server.common.MetadataVersion metadataVersion
      Default:
      IBP_4_2_IV1A

    • serverProperties

      ClusterConfigProperty[] serverProperties
      Default:
      {}

    • perBrokerOverrides

      ClusterConfigBrokerProperty[] perBrokerOverrides
      Default:
      {}

    • tags

      String[] tags
      Default:
      {}

    • features

      ClusterFeature[] features
      Default:
      {}