Uses of Class
io.strimzi.test.container.StrimziKafkaContainer

Uses of StrimziKafkaContainer in io.strimzi.test.container

Methods in io.strimzi.test.container that return StrimziKafkaContainer

Modifier and Type	Method	Description
StrimziKafkaContainer	StrimziKafkaContainer.waitForRunning()	Fluent method, which sets a waiting strategy to wait until the node is ready.
StrimziKafkaContainer	StrimziKafkaContainer.withAuthenticationType(AuthenticationType authType)	Sets the authentication type for the Kafka container.
StrimziKafkaContainer	StrimziKafkaContainer.withBootstrapServers(Function<StrimziKafkaContainer,String> provider)	Fluent method, assign provider for overriding bootstrap servers string
StrimziKafkaContainer	StrimziKafkaContainer.withKafkaConfigurationMap(Map<String,String> kafkaConfigurationMap)	Fluent method, which sets kafkaConfigurationMap.
StrimziKafkaContainer	StrimziKafkaContainer.withKafkaLog(org.apache.logging.log4j.Level level)	Configures the Kafka container to use the specified logging level for Kafka logs and the io.strimzi logger.
StrimziKafkaContainer	StrimziKafkaContainer.withKafkaVersion(String kafkaVersion)	Fluent method, which sets kafkaVersion.
StrimziKafkaContainer	StrimziKafkaContainer.withLogCollection()	Fluent method to enable log collection with a default log file path.
StrimziKafkaContainer	StrimziKafkaContainer.withLogCollection(String logFilePath)	Fluent method to enable log collection for all containers in the cluster with a custom log file path.
StrimziKafkaContainer	StrimziKafkaContainer.withNodeId(int nodeId)	Fluent method that sets the node ID.
StrimziKafkaContainer	StrimziKafkaContainer.withNodeRole(KafkaNodeRole nodeRole)	Fluent method to set the Kafka node role.
StrimziKafkaContainer	StrimziKafkaContainer.withOAuthConfig(String realm, String clientId, String clientSecret, String oauthUri, String usernameClaim)	Fluent method to configure OAuth settings.
StrimziKafkaContainer	StrimziKafkaContainer.withPort(int fixedPort)	Fluent method, which sets fixed exposed port.
StrimziKafkaContainer	StrimziKafkaContainer.withProxyContainer(org.testcontainers.toxiproxy.ToxiproxyContainer proxyContainer)	Fluent method, which sets a proxy container.
StrimziKafkaContainer	StrimziKafkaContainer.withSaslPassword(String saslPassword)	Fluent method to set the SASL PLAIN mechanism's password.
StrimziKafkaContainer	StrimziKafkaContainer.withSaslUsername(String saslUsername)	Fluent method to set the SASL PLAIN mechanism's username.

Methods in io.strimzi.test.container that return types with arguments of type StrimziKafkaContainer

Modifier and Type	Method	Description
Collection<StrimziKafkaContainer>	StrimziKafkaCluster.getBrokers()	Returns the broker nodes.
Collection<StrimziKafkaContainer>	StrimziKafkaCluster.getControllers()	Returns the controller nodes.
Collection<StrimziKafkaContainer>	StrimziKafkaCluster.getNodes()	Returns the underlying GenericContainer instances for all Kafka nodes in the cluster.

Method parameters in io.strimzi.test.container with type arguments of type StrimziKafkaContainer

Modifier and Type	Method	Description
StrimziKafkaCluster.StrimziKafkaClusterBuilder	StrimziKafkaCluster.StrimziKafkaClusterBuilder.withBootstrapServers(Function<StrimziKafkaContainer,String> provider)	Assigns a provider function for overriding the bootstrap servers string for all broker nodes.
StrimziKafkaContainer	StrimziKafkaContainer.withBootstrapServers(Function<StrimziKafkaContainer,String> provider)	Fluent method, assign provider for overriding bootstrap servers string
StrimziKafkaCluster.StrimziKafkaClusterBuilder	StrimziKafkaCluster.StrimziKafkaClusterBuilder.withContainerCustomizer(Consumer<StrimziKafkaContainer> customizer)	Assigns a customizer function to modify each Kafka container after its creation.