Index (test-common-runtime 8.1.3-ce API)

A B C D E F G H I J K L M N O P R S T U W
All Classes and Interfaces|All Packages|Constant Field Values

A

activeController() - Method in interface org.apache.kafka.common.test.ClusterInstance
activeController() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
addConfluentKeyValueStreamChangeRecord(OptionalLong, InternalTopicType, String, String, short, long) - Method in class org.apache.kafka.common.test.MockController
admin() - Method in interface org.apache.kafka.common.test.ClusterInstance
admin(Map<String, Object>) - Method in interface org.apache.kafka.common.test.ClusterInstance
admin(Map<String, Object>, boolean) - Method in interface org.apache.kafka.common.test.ClusterInstance
afterEach(ExtensionContext) - Method in class org.apache.kafka.common.test.junit.ClusterTestExtensions
aliveBrokers() - Method in interface org.apache.kafka.common.test.ClusterInstance
allocateProducerIds(ControllerRequestContext, AllocateProducerIdsRequestData) - Method in class org.apache.kafka.common.test.MockController
alterBrokerHealth(ControllerRequestContext, AlterBrokerHealthRequestData) - Method in class org.apache.kafka.common.test.MockController
alterBrokerReplicaExclusions(ControllerRequestContext, AlterBrokerReplicaExclusionsRequestData) - Method in class org.apache.kafka.common.test.MockController
alterCell(ControllerRequestContext, AlterCellRequest) - Method in class org.apache.kafka.common.test.MockController
alterCellMigration(ControllerRequestContext, AlterCellMigrationRequest) - Method in class org.apache.kafka.common.test.MockController
alterClientQuotas(ControllerRequestContext, Collection<ClientQuotaAlteration>, boolean) - Method in class org.apache.kafka.common.test.MockController
alterClusterLinks(ControllerRequestContext, AlterClusterLinksRequestData) - Method in class org.apache.kafka.common.test.MockController
alterMirrors(ControllerRequestContext, List<AlterMirrorsRequestData.MirrorOperation>, boolean) - Method in class org.apache.kafka.common.test.MockController
alterMirrorTopic(ControllerRequestContext, AlterMirrorTopicsRequestData) - Method in class org.apache.kafka.common.test.MockController
alterPartition(ControllerRequestContext, AlterPartitionRequestData) - Method in class org.apache.kafka.common.test.MockController
alterPartitionReassignments(ControllerRequestContext, AlterPartitionReassignmentsRequestData) - Method in class org.apache.kafka.common.test.MockController
alterUserScramCredentials(ControllerRequestContext, AlterUserScramCredentialsRequestData) - Method in class org.apache.kafka.common.test.MockController
anyBrokerSocketServer() - Method in interface org.apache.kafka.common.test.ClusterInstance: Return any one of the broker servers.
anyControllerSocketServer() - Method in interface org.apache.kafka.common.test.ClusterInstance: Return any one of the controller servers.
anyNonControllerBrokerSocketServer() - Method in interface org.apache.kafka.common.test.ClusterInstance
anyNonControllerBrokerSocketServer() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
assignBrokersToCell(ControllerRequestContext, AssignBrokersToCellRequest) - Method in class org.apache.kafka.common.test.MockController
assignReplicasToDirs(ControllerRequestContext, AssignReplicasToDirsRequestData) - Method in class org.apache.kafka.common.test.MockController
assignTenantsToCells(ControllerRequestContext, AssignTenantsToCellRequest) - Method in class org.apache.kafka.common.test.MockController
authorizers() - Method in interface org.apache.kafka.common.test.ClusterInstance

B

baseDirectory() - Method in class org.apache.kafka.common.test.TestKitNodes
beforeEach(ExtensionContext) - Method in class org.apache.kafka.common.test.junit.ClusterTestExtensions
beginShutdown() - Method in class org.apache.kafka.common.test.MockController
bootstrapControllers() - Method in interface org.apache.kafka.common.test.ClusterInstance: The broker connect string which can be used by clients for bootstrapping to the controller quorum.
bootstrapControllers() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
bootstrapControllers() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
bootstrapMetadata() - Method in class org.apache.kafka.common.test.TestKitNodes
bootstrapServers() - Method in interface org.apache.kafka.common.test.ClusterInstance: The broker connect string which can be used by clients for bootstrapping
bootstrapServers() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
bootstrapServers() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
brokerIds() - Method in interface org.apache.kafka.common.test.ClusterInstance: Return the set of all broker IDs configured for this test.
brokerListenerName() - Method in class org.apache.kafka.common.test.TestKitNodes
brokerListenerProtocol() - Method in class org.apache.kafka.common.test.TestKitNodes
brokerNodes() - Method in class org.apache.kafka.common.test.TestKitNodes
brokers() - Method in interface org.apache.kafka.common.test.ClusterInstance
brokers() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
brokers() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
brokersMap() - Method in interface org.apache.kafka.common.test.ClusterInstance
brokersMap() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
brokerSocketServers() - Method in interface org.apache.kafka.common.test.ClusterInstance: A collection of all brokers in the cluster.
build() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.Builder
build() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.ClientPropertiesBuilder
build() - Method in class org.apache.kafka.common.test.MockController.Builder
build() - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
Builder() - Constructor for class org.apache.kafka.common.test.MockController.Builder
Builder() - Constructor for class org.apache.kafka.common.test.TestKitNodes.Builder
Builder(TestKitNodes) - Constructor for class org.apache.kafka.common.test.KafkaClusterTestKit.Builder
Builder(BootstrapMetadata) - Constructor for class org.apache.kafka.common.test.TestKitNodes.Builder

C

clientListener() - Method in interface org.apache.kafka.common.test.ClusterInstance: The listener for this cluster as configured by ClusterTest or by ClusterConfig.
clientListener() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
clientProperties() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
ClientPropertiesBuilder() - Constructor for class org.apache.kafka.common.test.KafkaClusterTestKit.ClientPropertiesBuilder
ClientPropertiesBuilder(Properties) - Constructor for class org.apache.kafka.common.test.KafkaClusterTestKit.ClientPropertiesBuilder
close() - Method in class io.confluent.license.validator.DummyLicenseValidator
close() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
close() - Method in class org.apache.kafka.common.test.MockController
close() - Method in class org.apache.kafka.common.test.PreboundSocketFactoryManager
clusterId() - Method in interface org.apache.kafka.common.test.ClusterInstance
clusterId() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
clusterId() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
clusterId() - Method in class org.apache.kafka.common.test.TestKitNodes
ClusterInstance - Interface in org.apache.kafka.common.test
ClusterInstanceParameterResolver - Class in org.apache.kafka.common.test.junit: This resolver provides an instance of ClusterInstance to a test invocation.
ClusterInstanceParameterResolver(ClusterInstance) - Constructor for class org.apache.kafka.common.test.junit.ClusterInstanceParameterResolver
ClusterTestExtensions - Class in org.apache.kafka.common.test.junit: This class is a custom JUnit extension that will generate some number of test invocations depending on the processing of a few custom annotations.
ClusterTestExtensions() - Constructor for class org.apache.kafka.common.test.junit.ClusterTestExtensions
config() - Method in interface org.apache.kafka.common.test.ClusterInstance: The immutable cluster configuration used to create this cluster.
config() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
configure(Map<String, ?>) - Method in class io.confluent.license.validator.DummyLicenseValidator
consumer() - Method in interface org.apache.kafka.common.test.ClusterInstance
consumer(Map<String, Object>) - Method in interface org.apache.kafka.common.test.ClusterInstance
contextName() - Method in record class org.apache.kafka.common.test.JaasUtils.JaasSection: Returns the value of the contextName record component.
controllerIds() - Method in interface org.apache.kafka.common.test.ClusterInstance: Return the set of all controller IDs configured for this test.
controllerIds() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
controllerListener() - Method in interface org.apache.kafka.common.test.ClusterInstance
controllerListener() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
controllerListenerName() - Method in interface org.apache.kafka.common.test.ClusterInstance: The listener for the kraft cluster controller configured by controller.listener.names.
controllerListenerName() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
controllerListenerName() - Method in class org.apache.kafka.common.test.TestKitNodes
controllerListenerProtocol() - Method in class org.apache.kafka.common.test.TestKitNodes
controllerNodes() - Method in class org.apache.kafka.common.test.TestKitNodes
controllers() - Method in interface org.apache.kafka.common.test.ClusterInstance
controllers() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
controllers() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
controllerSocketServers() - Method in interface org.apache.kafka.common.test.ClusterInstance: A collection of all controllers in the cluster.
controllerSocketServers() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
createAcls(ControllerRequestContext, List<AclBinding>) - Method in class org.apache.kafka.common.test.MockController
createAcls(ControllerRequestContext, List<AclBinding>, AclState) - Method in class org.apache.kafka.common.test.MockController
createCell(ControllerRequestContext, CreateCellRequest) - Method in class org.apache.kafka.common.test.MockController
createClusterLinks(ControllerRequestContext, CreateClusterLinksRequestData, KafkaPrincipal) - Method in class org.apache.kafka.common.test.MockController
createDelegationToken(ControllerRequestContext, CreateDelegationTokenRequestData) - Method in class org.apache.kafka.common.test.MockController
createPartitions(ControllerRequestContext, List<CreatePartitionsRequestData.CreatePartitionsTopic>, boolean) - Method in class org.apache.kafka.common.test.MockController
createTopic(String, int, short) - Method in interface org.apache.kafka.common.test.ClusterInstance
createTopic(String, int, short, Map<String, String>) - Method in interface org.apache.kafka.common.test.ClusterInstance
createTopics(ControllerRequestContext, CreateTopicsRequestData, Set<String>) - Method in class org.apache.kafka.common.test.MockController
curClaimEpoch() - Method in class org.apache.kafka.common.test.MockController

D

debug() - Method in record class org.apache.kafka.common.test.JaasModule: Returns the value of the debug record component.
deleteAcls(ControllerRequestContext, List<AclBindingFilter>) - Method in class org.apache.kafka.common.test.MockController
deleteAcls(ControllerRequestContext, List<AclBindingFilter>, AclState) - Method in class org.apache.kafka.common.test.MockController
deleteCell(ControllerRequestContext, DeleteCellRequest) - Method in class org.apache.kafka.common.test.MockController
deleteClusterLinks(ControllerRequestContext, DeleteClusterLinksRequestData) - Method in class org.apache.kafka.common.test.MockController
deleteTenants(ControllerRequestContext, DeleteTenantsRequest) - Method in class org.apache.kafka.common.test.MockController
deleteTopic(String) - Method in interface org.apache.kafka.common.test.ClusterInstance: Deletes a topic and waits for the deletion to complete.
deleteTopics(ControllerRequestContext, Collection<Uuid>) - Method in class org.apache.kafka.common.test.MockController
describeBrokerHealth(ControllerRequestContext) - Method in class org.apache.kafka.common.test.MockController
describeBrokerReplicaExclusions(ControllerRequestContext) - Method in class org.apache.kafka.common.test.MockController
describeCellMigration(ControllerRequestContext, DescribeCellMigrationRequest) - Method in class org.apache.kafka.common.test.MockController
describeCells(ControllerRequestContext, DescribeCellsRequest) - Method in class org.apache.kafka.common.test.MockController
describeConfigs(ControllerRequestContext, Map<ConfigResource, Collection<String>>) - Method in class org.apache.kafka.common.test.MockController
describeTenants(ControllerRequestContext, DescribeTenantsRequest) - Method in class org.apache.kafka.common.test.MockController
DIGITS - Static variable in class org.apache.kafka.common.test.TestUtils
DummyLicenseTrackingInfoHolder() - Constructor for class io.confluent.license.validator.DummyLicenseValidator.DummyLicenseTrackingInfoHolder
DummyLicenseValidator - Class in io.confluent.license.validator: A dummy implementation of LicenseValidator for use with integration tests.
DummyLicenseValidator() - Constructor for class io.confluent.license.validator.DummyLicenseValidator
DummyLicenseValidator.DummyLicenseTrackingInfoHolder - Class in io.confluent.license.validator
duplicateCluster(Consumer<ClusterConfig.Builder>) - Method in interface org.apache.kafka.common.test.ClusterInstance
duplicateCluster(Consumer<ClusterConfig.Builder>) - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance

E

electLeaders(ControllerRequestContext, ElectLeadersRequestData) - Method in class org.apache.kafka.common.test.MockController
enabled() - Method in class io.confluent.license.validator.DummyLicenseValidator
endpointToString(Endpoint) - Static method in class org.apache.kafka.common.test.TestUtils: Convert EndPoint to String
entries() - Method in record class org.apache.kafka.common.test.JaasModule: Returns the value of the entries record component.
equals(Object) - Method in record class org.apache.kafka.common.test.JaasModule: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.apache.kafka.common.test.JaasUtils.JaasSection: Indicates whether some other object is "equal to" this one.
expireDelegationToken(ControllerRequestContext, ExpireDelegationTokenRequestData) - Method in class org.apache.kafka.common.test.MockController

F

fatalFaultHandler() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
finalizedFeatures(ControllerRequestContext) - Method in class org.apache.kafka.common.test.MockController
findAllTopicIds(ControllerRequestContext) - Method in class org.apache.kafka.common.test.MockController
findTopicIds(ControllerRequestContext, Collection<String>) - Method in class org.apache.kafka.common.test.MockController
findTopicNames(ControllerRequestContext, Collection<Uuid>) - Method in class org.apache.kafka.common.test.MockController
firstException() - Method in class org.apache.kafka.common.test.MockFaultHandler
firstFatalException() - Method in interface org.apache.kafka.common.test.ClusterInstance: Returns the first recorded fatal exception, if any.
firstFatalException() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
firstNonFatalException() - Method in interface org.apache.kafka.common.test.ClusterInstance: Return the first recorded non-fatal exception, if any.
firstNonFatalException() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
format() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
format() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit

G

get() - Method in class io.confluent.license.validator.DummyLicenseValidator
getAddConfluentKeyValueStreamChangeRecordCalls() - Method in class org.apache.kafka.common.test.MockController
getAdditionalExtensions() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext
getDisplayName(int) - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext
getLeaderBrokerId(TopicPartition) - Method in interface org.apache.kafka.common.test.ClusterInstance: Returns the broker id of leader partition.
getOrCreatePortForListener(int, String) - Method in class org.apache.kafka.common.test.PreboundSocketFactoryManager: Get a specific port number.
getOrCreateSocketFactory(int) - Method in class org.apache.kafka.common.test.PreboundSocketFactoryManager: Get or create a socket factory object associated with a given node ID.
getQuorumVotersConfig() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.Builder
getSocketForListenerAndMarkAsUsed(int, String) - Method in class org.apache.kafka.common.test.PreboundSocketFactoryManager: Get a socket from this manager, mark it as used, and return it.
getThreadIds() - Method in class org.apache.kafka.common.test.KafkaClusterThreadFactory
getTrackingId() - Method in class io.confluent.license.validator.DummyLicenseValidator.DummyLicenseTrackingInfoHolder
getUnderlying() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance

H

handleFault(String, Throwable) - Method in class org.apache.kafka.common.test.MockFaultHandler
hashCode() - Method in record class org.apache.kafka.common.test.JaasModule: Returns a hash code value for this object.
hashCode() - Method in record class org.apache.kafka.common.test.JaasUtils.JaasSection: Returns a hash code value for this object.

I

id() - Method in interface org.apache.kafka.common.test.TestKitNode
incrementalAlterConfigs(ControllerRequestContext, Map<ConfigResource, Map<String, Map.Entry<AlterConfigOp.OpType, String>>>, boolean) - Method in class org.apache.kafka.common.test.MockController
initialMetaPropertiesEnsemble() - Method in interface org.apache.kafka.common.test.TestKitNode
interBrokerPortFuture() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
interBrokerPortFuture() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
io.confluent.license.validator - package io.confluent.license.validator
isCombined(int) - Method in class org.apache.kafka.common.test.TestKitNodes
isLicenseValid() - Method in class io.confluent.license.validator.DummyLicenseValidator

J

JaasModule - Record Class in org.apache.kafka.common.test
JaasModule(String, boolean, Map<String, String>) - Constructor for record class org.apache.kafka.common.test.JaasModule: Creates an instance of a JaasModule record class.
JaasSection(String, List<JaasModule>) - Constructor for record class org.apache.kafka.common.test.JaasUtils.JaasSection: Creates an instance of a JaasSection record class.
JaasUtils - Class in org.apache.kafka.common.test
JaasUtils() - Constructor for class org.apache.kafka.common.test.JaasUtils
JaasUtils.JaasSection - Record Class in org.apache.kafka.common.test

K

KAFKA_PLAIN_ADMIN - Static variable in class org.apache.kafka.common.test.JaasUtils
KAFKA_PLAIN_ADMIN_PASSWORD - Static variable in class org.apache.kafka.common.test.JaasUtils
KAFKA_PLAIN_USER1 - Static variable in class org.apache.kafka.common.test.JaasUtils
KAFKA_PLAIN_USER1_PASSWORD - Static variable in class org.apache.kafka.common.test.JaasUtils
KAFKA_SERVER_CONTEXT_NAME - Static variable in class org.apache.kafka.common.test.JaasUtils
KafkaClusterTestKit - Class in org.apache.kafka.common.test
KafkaClusterTestKit.Builder - Class in org.apache.kafka.common.test
KafkaClusterTestKit.ClientPropertiesBuilder - Class in org.apache.kafka.common.test
KafkaClusterThreadFactory - Class in org.apache.kafka.common.test
killAllBrokers() - Method in interface org.apache.kafka.common.test.ClusterInstance
killAllBrokers() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance

L

legacyAlterConfigs(ControllerRequestContext, Map<ConfigResource, Map<String, String>>, boolean) - Method in class org.apache.kafka.common.test.MockController
LETTERS - Static variable in class org.apache.kafka.common.test.TestUtils
LETTERS_AND_DIGITS - Static variable in class org.apache.kafka.common.test.TestUtils
linkCoordinator(String) - Method in interface org.apache.kafka.common.test.ClusterInstance
linkCoordinator(String) - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
listPartitionReassignments(ControllerRequestContext, ListPartitionReassignmentsRequestData) - Method in class org.apache.kafka.common.test.MockController
logDataDirectories() - Method in interface org.apache.kafka.common.test.TestKitNode

M

maybeRethrowFirstException() - Method in class org.apache.kafka.common.test.MockFaultHandler
mayReturnZeroTestTemplateInvocationContexts(ExtensionContext) - Method in class org.apache.kafka.common.test.junit.ClusterTestExtensions: Indicates whether this provider may return zero test template invocation contexts.
metadataDirectory() - Method in interface org.apache.kafka.common.test.TestKitNode
metadataDirectoryId() - Method in interface org.apache.kafka.common.test.TestKitNode
metadataImage() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
MockController - Class in org.apache.kafka.common.test
MockController.Builder - Class in org.apache.kafka.common.test
MockFaultHandler - Class in org.apache.kafka.common.test: This is a fault handler suitable for use in JUnit tests.
MockFaultHandler(String) - Constructor for class org.apache.kafka.common.test.MockFaultHandler
modules() - Method in record class org.apache.kafka.common.test.JaasUtils.JaasSection: Returns the value of the modules record component.

N

name() - Method in record class org.apache.kafka.common.test.JaasModule: Returns the value of the name record component.
newClientPropertiesBuilder() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
newClientPropertiesBuilder(Properties) - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
newInitialTopic(String, Uuid) - Method in class org.apache.kafka.common.test.MockController.Builder
newInitialTopic(String, Uuid, int) - Method in class org.apache.kafka.common.test.MockController.Builder
newThread(Runnable) - Method in class org.apache.kafka.common.test.KafkaClusterThreadFactory
nodes() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
nonFatalFaultHandler() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit

O

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

P

plainLoginModule(String, String, boolean, Map<String, String>) - Static method in record class org.apache.kafka.common.test.JaasModule
PreboundSocketFactoryManager - Class in org.apache.kafka.common.test
PreboundSocketFactoryManager() - Constructor for class org.apache.kafka.common.test.PreboundSocketFactoryManager
processBrokerHeartbeat(ControllerRequestContext, BrokerHeartbeatRequestData) - Method in class org.apache.kafka.common.test.MockController
producer() - Method in interface org.apache.kafka.common.test.ClusterInstance
producer(Map<String, Object>) - Method in interface org.apache.kafka.common.test.ClusterInstance
propertyOverrides() - Method in interface org.apache.kafka.common.test.TestKitNode
provideTestTemplateInvocationContexts(ExtensionContext) - Method in class org.apache.kafka.common.test.junit.ClusterTestExtensions

R

RaftClusterInvocationContext - Class in org.apache.kafka.common.test.junit: Wraps a KafkaClusterTestKit inside lifecycle methods for a test invocation.
RaftClusterInvocationContext(String, ClusterConfig, boolean) - Constructor for class org.apache.kafka.common.test.junit.RaftClusterInvocationContext
RaftClusterInvocationContext.RaftClusterInstance - Class in org.apache.kafka.common.test.junit
raftManagers() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
randomString(int) - Static method in class org.apache.kafka.common.test.TestUtils: Generate a random string of letters and digits of the given length
readKeyValueStreamsTopicOffsets() - Method in class org.apache.kafka.common.test.MockController
refreshJavaLoginConfigParam(File) - Static method in class org.apache.kafka.common.test.JaasUtils
registerBroker(ControllerRequestContext, BrokerRegistrationRequestData) - Method in class org.apache.kafka.common.test.MockController
registerController(ControllerRequestContext, ControllerRegistrationRequestData) - Method in class org.apache.kafka.common.test.MockController
renewDelegationToken(ControllerRequestContext, RenewDelegationTokenRequestData) - Method in class org.apache.kafka.common.test.MockController
resolveParameter(ParameterContext, ExtensionContext) - Method in class org.apache.kafka.common.test.junit.ClusterInstanceParameterResolver
rollingBrokerRestart() - Method in interface org.apache.kafka.common.test.ClusterInstance
rollingBrokerRestart() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance

S

SEEDED_RANDOM - Static variable in class org.apache.kafka.common.test.TestUtils
setActive(boolean) - Method in class org.apache.kafka.common.test.MockController
setBaseDirectory(Path) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setBootstrapMetadata(BootstrapMetadata) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setBootstrapMetadataVersion(MetadataVersion) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setBrokerListenerName(ListenerName) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setBrokerSecurityProtocol(SecurityProtocol) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setClientSaslConfig(Map<String, Object>) - Method in interface org.apache.kafka.common.test.ClusterInstance
setClusterId(String) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setCombined(boolean) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setConfigProp(String, Object) - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.Builder
setControllerListenerName(ListenerName) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setControllerSecurityProtocol(SecurityProtocol) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setDeleteOnClose(boolean) - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.Builder
setExpectedAlterConfigsPrincipals(Iterator<KafkaPrincipal>) - Method in class org.apache.kafka.common.test.MockController.Builder
setExpectedAlterExclusionResultSuccess(Boolean) - Method in class org.apache.kafka.common.test.MockController.Builder
setIgnore(boolean) - Method in class org.apache.kafka.common.test.MockFaultHandler
setInitialVoterSet(Map<Integer, Uuid>) - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.Builder
setNumBrokerNodes(int) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setNumControllerNodes(int) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setNumDisksPerBroker(int) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setPerServerProperties(Map<Integer, Map<String, String>>) - Method in class org.apache.kafka.common.test.TestKitNodes.Builder
setStandalone(boolean) - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.Builder
setUsingBootstrapControllers(boolean) - Method in class org.apache.kafka.common.test.KafkaClusterTestKit.ClientPropertiesBuilder
shareConsumer() - Method in interface org.apache.kafka.common.test.ClusterInstance
shareConsumer(Map<String, Object>) - Method in interface org.apache.kafka.common.test.ClusterInstance
shutdownAll() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
shutdownBroker(int) - Method in interface org.apache.kafka.common.test.ClusterInstance
shutdownBroker(int) - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
start() - Method in interface org.apache.kafka.common.test.ClusterInstance
start() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
start(String) - Method in class io.confluent.license.validator.DummyLicenseValidator
startBroker(int) - Method in interface org.apache.kafka.common.test.ClusterInstance
startBroker(int) - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
started() - Method in interface org.apache.kafka.common.test.ClusterInstance
started() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
startup() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
stop() - Method in interface org.apache.kafka.common.test.ClusterInstance
stop() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
stopped() - Method in interface org.apache.kafka.common.test.ClusterInstance
stopped() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
supportedGroupProtocols() - Method in interface org.apache.kafka.common.test.ClusterInstance
supportsParameter(ParameterContext, ExtensionContext) - Method in class org.apache.kafka.common.test.junit.ClusterInstanceParameterResolver
supportsTestTemplate(ExtensionContext) - Method in class org.apache.kafka.common.test.junit.ClusterTestExtensions

T

tempFile() - Static method in class org.apache.kafka.common.test.TestUtils: Create an empty file in the default temporary-file directory, using `kafka` as the prefix and `tmp` as the suffix to generate its name.
TestKitNode - Interface in org.apache.kafka.common.test
TestKitNodes - Class in org.apache.kafka.common.test
TestKitNodes.Builder - Class in org.apache.kafka.common.test
TestUtils - Class in org.apache.kafka.common.test: Helper functions for writing unit tests
TestUtils() - Constructor for class org.apache.kafka.common.test.TestUtils
toString() - Method in record class org.apache.kafka.common.test.JaasModule: Returns a string representation of this record class.
toString() - Method in record class org.apache.kafka.common.test.JaasUtils.JaasSection: Returns a string representation of this record class.
type() - Method in interface org.apache.kafka.common.test.ClusterInstance
type() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance

U

unassignBrokersFromCell(ControllerRequestContext, UnAssignBrokersFromCellRequest) - Method in class org.apache.kafka.common.test.MockController
unfencedBrokerEndpoints(ControllerRequestContext, ListenerName) - Method in class org.apache.kafka.common.test.MockController
unregisterBroker(ControllerRequestContext, int) - Method in class org.apache.kafka.common.test.MockController
updateFeatures(ControllerRequestContext, UpdateFeaturesRequestData) - Method in class org.apache.kafka.common.test.MockController

W

waitAcls(AclBindingFilter, Collection<AccessControlEntry>) - Method in interface org.apache.kafka.common.test.ClusterInstance
waitForActiveController() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit
waitForCondition(Supplier<Boolean>, long, String) - Static method in class org.apache.kafka.common.test.TestUtils: Wait for condition to be met for at most maxWaitMs and throw assertion failure otherwise.
waitForCondition(Supplier<Boolean>, long, Supplier<String>) - Static method in class org.apache.kafka.common.test.TestUtils: Wait for condition to be met for at most maxWaitMs and throw assertion failure otherwise.
waitForCondition(Supplier<Boolean>, String) - Static method in class org.apache.kafka.common.test.TestUtils: uses default value of 15 seconds for timeout
waitForReadyBrokers() - Method in interface org.apache.kafka.common.test.ClusterInstance
waitForReadyBrokers() - Method in class org.apache.kafka.common.test.junit.RaftClusterInvocationContext.RaftClusterInstance
waitForReadyBrokers() - Method in class org.apache.kafka.common.test.KafkaClusterTestKit: Wait for a controller to mark all the brokers as ready (registered and unfenced).
waitForReadyBrokers(int) - Method in class org.apache.kafka.common.test.MockController
waitForTopic(String, int) - Method in interface org.apache.kafka.common.test.ClusterInstance
waitTopicDeletion(String) - Method in interface org.apache.kafka.common.test.ClusterInstance
waitUntilLeaderIsElectedOrChangedWithAdmin(Admin, String, int, long) - Static method in class org.apache.kafka.common.test.TestUtils
writeJaasContextsToFile(Set<JaasUtils.JaasSection>) - Static method in class org.apache.kafka.common.test.JaasUtils

A B C D E F G H I J K L M N O P R S T U W
All Classes and Interfaces|All Packages|Constant Field Values