Index (Strimzi test container 0.115.0 API)

A B C G I K N O S U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AuthenticationType - Enum in io.strimzi.test.container: Enum representing authentication types for StrimziKafkaContainer.

B

BROKER - Enum constant in enum io.strimzi.test.container.KafkaNodeRole: Broker-only node that handles client requests and stores topic data but does not participate in the metadata quorum.
build() - Method in class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder: Build and return a StrimziConnectCluster instance based on the provided configurations.
build() - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Builds and returns a StrimziKafkaCluster instance based on the provided configurations.

C

COMBINED - Enum constant in enum io.strimzi.test.container.KafkaNodeRole: Combined node that acts as both broker and controller.
CONTROLLER - Enum constant in enum io.strimzi.test.container.KafkaNodeRole: Controller-only node that participates in the metadata quorum but does not handle client requests or store topic data.
CONTROLLER_PORT - Static variable in class io.strimzi.test.container.StrimziKafkaContainer: Default Kafka controller port

G

getAuthenticationType() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the authentication type configured for this container.
getBootstrapControllers() - Method in interface io.strimzi.test.container.KafkaContainer: Get the Kafka controller bootstrap servers for admin operations that require controller access.
getBootstrapControllers() - Method in class io.strimzi.test.container.StrimziKafkaCluster: Get the bootstrap controllers that can be used for controller operations
getBootstrapControllers() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Retrieves the bootstrap controllers URL for admin clients that need to connect to controllers.
getBootstrapServers() - Method in interface io.strimzi.test.container.KafkaContainer: Get the Kafka cluster bootstrap servers.
getBootstrapServers() - Method in class io.strimzi.test.container.StrimziKafkaCluster
getBootstrapServers() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Retrieves the bootstrap servers URL for Kafka clients.
getBrokers() - Method in class io.strimzi.test.container.StrimziKafkaCluster: Returns the broker nodes.
getClientId() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the OAuth client ID.
getClientSecret() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the OAuth client secret.
getClusterId() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Get the cluster id.
getControllers() - Method in class io.strimzi.test.container.StrimziKafkaCluster: Returns the controller nodes.
getNetworkBootstrapControllers() - Method in class io.strimzi.test.container.StrimziKafkaCluster: Get the bootstrap controllers that containers on the same network should use to connect to controllers
getNetworkBootstrapControllers() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Get the bootstrap controllers that containers on the same network should use to connect to controllers
getNetworkBootstrapServers() - Method in class io.strimzi.test.container.StrimziKafkaCluster: Get the bootstrap servers that containers on the same network should use to connect
getNetworkBootstrapServers() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Get the bootstrap servers that containers on the same network should use to connect
getNodeId() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the node ID for this Kafka container.
getNodeRole() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the node role for this Kafka container.
getNodes() - Method in class io.strimzi.test.container.StrimziKafkaCluster: Returns the underlying GenericContainer instances for all Kafka nodes in the cluster.
getOauthUri() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the OAuth URI.
getProcessRoles() - Method in enum io.strimzi.test.container.KafkaNodeRole: Returns the Kafka process.roles configuration value for this node role.
getProxy() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Retrieves the Proxy instance for this Kafka broker.
getProxyForNode(int) - Method in class io.strimzi.test.container.StrimziKafkaCluster: Retrieves the Proxy instance for a specific node by its node ID.
getRealm() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the OAuth realm.
getRestEndpoint() - Method in class io.strimzi.test.container.StrimziConnectCluster: Return the REST API endpoint of one of the available workers.
getSaslPassword() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the SASL password for authentication.
getSaslUsername() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the SASL username for authentication.
getSupportedKafkaVersions() - Static method in class io.strimzi.test.container.StrimziKafkaCluster: Get list of all supported Kafka versions.
getUsernameClaim() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Gets the OAuth username claim.
getWorkers() - Method in class io.strimzi.test.container.StrimziConnectCluster: Get the workers of this Kafka Connect cluster.
GSSAPI - Enum constant in enum io.strimzi.test.container.AuthenticationType: GSSAPI (Kerberos) authentication.

I

io.strimzi.test.container - package io.strimzi.test.container
isBroker() - Method in enum io.strimzi.test.container.KafkaNodeRole: Checks if this node role includes broker functionality.
isController() - Method in enum io.strimzi.test.container.KafkaNodeRole: Checks if this node role includes controller functionality.
isOAuthEnabled() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Checks if OAuth is enabled.
isUsingDedicatedRoles() - Method in class io.strimzi.test.container.StrimziKafkaCluster: Checks if the cluster is using dedicated controller/broker roles.

K

KAFKA_PORT - Static variable in class io.strimzi.test.container.StrimziKafkaContainer: Default Kafka port
KafkaContainer - Interface in io.strimzi.test.container: KafkaContainer is an interface that represents a Kafka container.
KafkaNodeRole - Enum in io.strimzi.test.container: Internal: Enum representing the different roles a Kafka node can have in KRaft mode.

N

NONE - Enum constant in enum io.strimzi.test.container.AuthenticationType: No authentication.

O

OAUTH_BEARER - Enum constant in enum io.strimzi.test.container.AuthenticationType: OAuth Bearer token authentication.
OAUTH_OVER_PLAIN - Enum constant in enum io.strimzi.test.container.AuthenticationType: OAuth authentication over plain text.

S

SCRAM_SHA_256 - Enum constant in enum io.strimzi.test.container.AuthenticationType: SCRAM-SHA-256 authentication.
SCRAM_SHA_512 - Enum constant in enum io.strimzi.test.container.AuthenticationType: SCRAM-SHA-512 authentication.
start() - Method in class io.strimzi.test.container.StrimziConnectCluster: Start the Kafka Connect cluster.
start() - Method in class io.strimzi.test.container.StrimziKafkaCluster
STARTER_SCRIPT - Static variable in class io.strimzi.test.container.StrimziKafkaContainer: The file containing the startup script.
stop() - Method in class io.strimzi.test.container.StrimziConnectCluster: Stop the Kafka Connect cluster.
stop() - Method in class io.strimzi.test.container.StrimziKafkaCluster
stop() - Method in class io.strimzi.test.container.StrimziKafkaContainer
StrimziConnectCluster - Class in io.strimzi.test.container: A Kafka Connect cluster using the latest image from quay.io/strimzi/kafka with the given version.
StrimziConnectCluster(StrimziConnectCluster.StrimziConnectClusterBuilder) - Constructor for class io.strimzi.test.container.StrimziConnectCluster: Creates a new StrimziConnectCluster using the provided builder.
StrimziConnectCluster.StrimziConnectClusterBuilder - Class in io.strimzi.test.container: Builder class for StrimziConnectCluster.
StrimziConnectClusterBuilder() - Constructor for class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder
StrimziKafkaCluster - Class in io.strimzi.test.container: A multi-node instance of Kafka using the latest image from quay.io/strimzi/kafka with the given version.
StrimziKafkaCluster.StrimziKafkaClusterBuilder - Class in io.strimzi.test.container: Builder class for StrimziKafkaCluster.
StrimziKafkaClusterBuilder() - Constructor for class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder
StrimziKafkaContainer - Class in io.strimzi.test.container: StrimziKafkaContainer is a single-node instance of Kafka using the image from quay.io/strimzi/kafka with the given version.

U

UnknownKafkaVersionException - Exception in io.strimzi.test.container: Provides a handler, when KafkaVersionService.strimziTestContainerImageName(String) does not know the concrete Kafka version.
UnknownKafkaVersionException(String) - Constructor for exception io.strimzi.test.container.UnknownKafkaVersionException: UnknownKafkaVersionException used for handling situation, where KafkaVersionService.strimziTestContainerImageName(String) can not find Kafka version
UnknownKafkaVersionException(Throwable) - Constructor for exception io.strimzi.test.container.UnknownKafkaVersionException: UnknownKafkaVersionException used for handling situation, where KafkaVersionService.strimziTestContainerImageName(String) can not find Kafka version

V

valueOf(String) - Static method in enum io.strimzi.test.container.AuthenticationType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.strimzi.test.container.KafkaNodeRole: Returns the enum constant of this type with the specified name.
values() - Static method in enum io.strimzi.test.container.AuthenticationType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.strimzi.test.container.KafkaNodeRole: Returns an array containing the constants of this enum type, in the order they are declared.

W

WaitException - Exception in io.strimzi.test.container: Extension for RuntimeException used in active waiting.
WaitException(String) - Constructor for exception io.strimzi.test.container.WaitException: WaitException used for active waiting
WaitException(Throwable) - Constructor for exception io.strimzi.test.container.WaitException: WaitException used for active waiting
waitForRunning() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method, which sets a waiting strategy to wait until the node is ready.
withAdditionalConnectConfiguration(Map<String, String>) - Method in class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder: Add additional Kafka Connect configuration parameters.
withAdditionalKafkaConfiguration(Map<String, String>) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Adds additional Kafka configuration parameters.
withAuthenticationType(AuthenticationType) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets the authentication type for all nodes in the cluster.
withAuthenticationType(AuthenticationType) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Sets the authentication type for the Kafka container.
withBootstrapServers(Function<StrimziKafkaContainer, String>) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Assigns a provider function for overriding the bootstrap servers string for all broker nodes.
withBootstrapServers(Function<StrimziKafkaContainer, String>) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method, assign provider for overriding bootstrap servers string
withContainerCustomizer(Consumer<StrimziKafkaContainer>) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Assigns a customizer function to modify each Kafka container after its creation.
withDedicatedRoles() - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Configures the cluster to use dedicated controller and broker nodes instead of combined-role nodes.
withGroupId(String) - Method in class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder: Specify the group.id of the Connect cluster.
withImage(String) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Specifies a custom Docker image to be used for the Kafka brokers in the cluster.
withInternalTopicReplicationFactor(int) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets the internal topic replication factor for Kafka brokers.
withKafkaCluster(StrimziKafkaCluster) - Method in class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder: Set the Kafka cluster the Kafka Connect cluster will use to.
withKafkaConfigurationMap(Map<String, String>) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method, which sets kafkaConfigurationMap.
withKafkaLog(Level) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Configures the Kafka container to use the specified logging level for Kafka logs and the io.strimzi logger.
withKafkaVersion(String) - Method in class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder: Specify the Kafka version to be used for the Connect workers in the cluster.
withKafkaVersion(String) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Specifies the Kafka version to be used for the brokers in the cluster.
withKafkaVersion(String) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method, which sets kafkaVersion.
withLogCollection() - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Fluent method to enable log collection with a default log file path.
withLogCollection() - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method to enable log collection with a default log file path.
withLogCollection(String) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Fluent method to enable log collection for all containers in the cluster with a custom log file path.
withLogCollection(String) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method to enable log collection for all containers in the cluster with a custom log file path.
withNodeId(int) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method that sets the node ID.
withNodeRole(KafkaNodeRole) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method to set the Kafka node role.
withNumberOfBrokers(int) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets the number of Kafka brokers in the cluster.
withNumberOfControllers(int) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets the number of dedicated controller nodes when using combined roles.
withNumberOfWorkers(int) - Method in class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder: Set the number of Kafka Connect workers in the cluster.
withOAuthConfig(String, String, String, String, String) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Configures OAuth settings for all nodes in the cluster.
withOAuthConfig(String, String, String, String, String) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method to configure OAuth settings.
withoutFileConnectors() - Method in class io.strimzi.test.container.StrimziConnectCluster.StrimziConnectClusterBuilder: Disable the FileStreams connectors.
withPort(int) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets a fixed exposed port for all broker nodes in the cluster.
withPort(int) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method, which sets fixed exposed port.
withProxyContainer(ToxiproxyContainer) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets a ToxiproxyContainer to simulate network conditions such as latency or disconnection.
withProxyContainer(ToxiproxyContainer) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method, which sets a proxy container.
withSaslPassword(String) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets the SASL password for OAuth over PLAIN authentication.
withSaslPassword(String) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method to set the SASL PLAIN mechanism's password.
withSaslUsername(String) - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Sets the SASL username for OAuth over PLAIN authentication.
withSaslUsername(String) - Method in class io.strimzi.test.container.StrimziKafkaContainer: Fluent method to set the SASL PLAIN mechanism's username.
withSharedNetwork() - Method in class io.strimzi.test.container.StrimziKafkaCluster.StrimziKafkaClusterBuilder: Enables a shared Docker network for the Kafka cluster.

A B C G I K N O S U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form