Uses of Class
io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder
-
Uses of StrimziKafkaCluster.StrimziKafkaClusterBuilder in io.strimzi.test.container
Methods in io.strimzi.test.container that return StrimziKafkaCluster.StrimziKafkaClusterBuilderModifier and TypeMethodDescriptionStrimziKafkaCluster.StrimziKafkaClusterBuilder.withAdditionalKafkaConfiguration(Map<String, String> additionalKafkaConfiguration) Adds additional Kafka configuration parameters.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withAuthenticationType(AuthenticationType authType) Sets the authentication type for all nodes in the cluster.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withBootstrapServers(Function<StrimziKafkaContainer, String> provider) Assigns a provider function for overriding the bootstrap servers string for all broker nodes.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withContainerCustomizer(Consumer<StrimziKafkaContainer> customizer) Assigns a customizer function to modify each Kafka container after its creation.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withDedicatedRoles()Configures the cluster to use dedicated controller and broker nodes instead of combined-role nodes.Specifies a custom Docker image to be used for the Kafka brokers in the cluster.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withInternalTopicReplicationFactor(int internalTopicReplicationFactor) Sets the internal topic replication factor for Kafka brokers.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withKafkaVersion(String kafkaVersion) Specifies the Kafka version to be used for the brokers in the cluster.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withLogCollection()Fluent method to enable log collection with a default log file path.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withLogCollection(String logFilePath) Fluent method to enable log collection for all containers in the cluster with a custom log file path.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withNumberOfBrokers(int brokersNum) Sets the number of Kafka brokers in the cluster.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withNumberOfControllers(int controllersNum) Sets the number of dedicated controller nodes when using combined roles.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withOAuthConfig(String realm, String clientId, String clientSecret, String oauthUri, String usernameClaim) Configures OAuth settings for all nodes in the cluster.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withPort(int fixedPort) Sets a fixed exposed port for all broker nodes in the cluster.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withProxyContainer(org.testcontainers.toxiproxy.ToxiproxyContainer proxyContainer) Sets aToxiproxyContainerto simulate network conditions such as latency or disconnection.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withSaslPassword(String saslPassword) Sets the SASL password for OAuth over PLAIN authentication.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withSaslUsername(String saslUsername) Sets the SASL username for OAuth over PLAIN authentication.StrimziKafkaCluster.StrimziKafkaClusterBuilder.withSharedNetwork()Enables a shared Docker network for the Kafka cluster.