Index

A B C D E F H I K M N O P S T V Y
All Classes and Interfaces|All Packages|Constant Field Values

A

adminClientProperties() - Method in class org.apache.kafka.common.test.api.ClusterConfig

ALL_NON_CORESIDENT - Enum constant in enum class org.apache.kafka.common.test.api.Type

autoStart() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

autoStart() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTestDefaults

AutoStart - Enum Class in org.apache.kafka.common.test.api

B

BROKER_ID_OFFSET - Static variable in class org.apache.kafka.common.test.api.TestKitDefaults

brokerId() - Element in annotation interface org.apache.kafka.common.test.api.ClusterConfigBrokerProperty

brokerListener() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

brokerListenerName() - Method in class org.apache.kafka.common.test.api.ClusterConfig

brokers() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

brokers() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTestDefaults

brokerSecurityProtocol() - Method in class org.apache.kafka.common.test.api.ClusterConfig

brokerSecurityProtocol() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

build() - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

builder() - Static method in class org.apache.kafka.common.test.api.ClusterConfig

builder(ClusterConfig) - Static method in class org.apache.kafka.common.test.api.ClusterConfig

C

ClusterConfig - Class in org.apache.kafka.common.test.api

Represents an immutable requested configuration of a Kafka cluster for integration testing.

ClusterConfig.Builder - Class in org.apache.kafka.common.test.api

ClusterConfigBrokerProperty - Annotation Interface in org.apache.kafka.common.test.api

ClusterConfigProperty - Annotation Interface in org.apache.kafka.common.test.api

ClusterFeature - Annotation Interface in org.apache.kafka.common.test.api

ClusterGenerator - Interface in org.apache.kafka.common.test.api

ClusterTemplate - Annotation Interface in org.apache.kafka.common.test.api

Used to indicate that a test should call the method given by ClusterTemplate.value() to generate a number of cluster configurations.

ClusterTest - Annotation Interface in org.apache.kafka.common.test.api

ClusterTestDefaults - Annotation Interface in org.apache.kafka.common.test.api

Used to set class level defaults for any test template methods annotated with ClusterTest or ClusterTests.

ClusterTests - Annotation Interface in org.apache.kafka.common.test.api

clusterTypes() - Method in class org.apache.kafka.common.test.api.ClusterConfig

CO_KRAFT - Enum constant in enum class org.apache.kafka.common.test.api.Type

consumerProperties() - Method in class org.apache.kafka.common.test.api.ClusterConfig

CONTROLLER_ID_OFFSET - Static variable in class org.apache.kafka.common.test.api.TestKitDefaults

controllerListener() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

controllerListenerName() - Method in class org.apache.kafka.common.test.api.ClusterConfig

controllers() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

controllers() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTestDefaults

controllerSecurityProtocol() - Method in class org.apache.kafka.common.test.api.ClusterConfig

controllerSecurityProtocol() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

copyOf() - Method in class org.apache.kafka.common.test.api.ClusterConfig

copyOf(Consumer<ClusterConfig.Builder>) - Method in class org.apache.kafka.common.test.api.ClusterConfig

D

DEFAULT - Enum constant in enum class org.apache.kafka.common.test.api.AutoStart

DEFAULT_BROKER_LISTENER_NAME - Static variable in class org.apache.kafka.common.test.api.TestKitDefaults

DEFAULT_BROKER_SECURITY_PROTOCOL - Static variable in class org.apache.kafka.common.test.api.TestKitDefaults

DEFAULT_CONTROLLER_LISTENER_NAME - Static variable in class org.apache.kafka.common.test.api.TestKitDefaults

DEFAULT_CONTROLLER_SECURITY_PROTOCOL - Static variable in class org.apache.kafka.common.test.api.TestKitDefaults

defaultBuilder() - Static method in class org.apache.kafka.common.test.api.ClusterConfig

DetectThreadLeak - Interface in org.apache.kafka.common.test.api

disksPerBroker() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

disksPerBroker() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTestDefaults

displayTags() - Method in class org.apache.kafka.common.test.api.ClusterConfig

E

equals(Object) - Method in class org.apache.kafka.common.test.api.ClusterConfig

F

feature() - Element in annotation interface org.apache.kafka.common.test.api.ClusterFeature

features() - Method in class org.apache.kafka.common.test.api.ClusterConfig

features() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

firstBrokerId() - Method in class org.apache.kafka.common.test.api.ClusterConfig

H

hashCode() - Method in class org.apache.kafka.common.test.api.ClusterConfig

I

id() - Element in annotation interface org.apache.kafka.common.test.api.ClusterConfigProperty

The config applies to the controller/broker with specified id.

isAutoStart() - Method in class org.apache.kafka.common.test.api.ClusterConfig

K

key() - Element in annotation interface org.apache.kafka.common.test.api.ClusterConfigProperty

KRAFT - Enum constant in enum class org.apache.kafka.common.test.api.Type

M

metadataVersion() - Method in class org.apache.kafka.common.test.api.ClusterConfig

metadataVersion() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

N

newThreads() - Method in interface org.apache.kafka.common.test.api.DetectThreadLeak

NO - Enum constant in enum class org.apache.kafka.common.test.api.AutoStart

numBrokers() - Method in class org.apache.kafka.common.test.api.ClusterConfig

numControllers() - Method in class org.apache.kafka.common.test.api.ClusterConfig

numDisksPerBroker() - Method in class org.apache.kafka.common.test.api.ClusterConfig

O

of(Predicate<Thread>) - Static method in interface org.apache.kafka.common.test.api.DetectThreadLeak

Creates an instance of DetectThreadLeak that filters threads based on a given predicate.

org.apache.kafka.common.test.api - package org.apache.kafka.common.test.api

P

perBrokerOverrides() - Element in annotation interface org.apache.kafka.common.test.api.ClusterConfigBrokerProperty

perBrokerOverrides() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

perBrokerOverrides() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTestDefaults

perServerOverrideProperties() - Method in class org.apache.kafka.common.test.api.ClusterConfig

producerProperties() - Method in class org.apache.kafka.common.test.api.ClusterConfig

S

saslClientProperties() - Method in class org.apache.kafka.common.test.api.ClusterConfig

saslServerProperties() - Method in class org.apache.kafka.common.test.api.ClusterConfig

serverProperties() - Method in class org.apache.kafka.common.test.api.ClusterConfig

serverProperties() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

serverProperties() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTestDefaults

setAdminClientProperties(Map<String, String>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setAutoStart(boolean) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setBrokerListenerName(ListenerName) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setBrokers(int) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setBrokerSecurityProtocol(SecurityProtocol) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setConsumerProperties(Map<String, String>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setControllerListenerName(ListenerName) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setControllers(int) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setControllerSecurityProtocol(SecurityProtocol) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setDisksPerBroker(int) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setFeatures(Map<Feature, Short>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setFirstBrokerId(Integer) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setMetadataVersion(MetadataVersion) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setPerServerProperties(Map<Integer, Map<String, String>>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setProducerProperties(Map<String, String>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setSaslClientProperties(Map<String, String>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setSaslServerProperties(Map<String, String>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setServerProperties(Map<String, String>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setTags(List<String>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setTrustStoreFile(File) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

setTypes(Set<Type>) - Method in class org.apache.kafka.common.test.api.ClusterConfig.Builder

T

tags() - Method in class org.apache.kafka.common.test.api.ClusterConfig

tags() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

TestKitDefaults - Class in org.apache.kafka.common.test.api

Constants used by TestKitNodes and ClusterTest annotation defaults

trustStoreFile() - Method in class org.apache.kafka.common.test.api.ClusterConfig

Type - Enum Class in org.apache.kafka.common.test.api

The type of cluster config being requested.

types() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTest

types() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTestDefaults

V

value() - Element in annotation interface org.apache.kafka.common.test.api.ClusterConfigProperty

value() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTemplate

Specify the static method used for generating cluster configs

value() - Element in annotation interface org.apache.kafka.common.test.api.ClusterTests

valueOf(String) - Static method in enum class org.apache.kafka.common.test.api.AutoStart

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class org.apache.kafka.common.test.api.Type

Returns the enum constant of this class with the specified name.

values() - Static method in enum class org.apache.kafka.common.test.api.AutoStart

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class org.apache.kafka.common.test.api.Type

Returns an array containing the constants of this enum class, in the order they are declared.

version() - Element in annotation interface org.apache.kafka.common.test.api.ClusterFeature

Y

YES - Enum constant in enum class org.apache.kafka.common.test.api.AutoStart

A B C D E F H I K M N O P S T V Y
All Classes and Interfaces|All Packages|Constant Field Values