Skip navigation links
C D E G I J K L M O P R S T U V W 

C

call(Callable<T>, String) - Method in class kafka.tier.compatibility.Logger
Given a generic callable method & an operation name, if debug mode is enabled, prints the execution time taken.
checkBytesFetchedFromLocalLog(int) - Method in class kafka.tier.compatibility.JmxMetricsAnalyzer
Checks that the number of bytes fetched from a local log is within the given threshold
checkTieringCompleted(AdminClient, String, int, String, boolean, int, boolean, String, String, int) - Static method in class kafka.tier.compatibility.TierTestUtils
A helper function which periodically checks if tiering has completed by quering JMX metrics & analyzing them.
checkTierSize() - Method in class kafka.tier.compatibility.JmxMetricsAnalyzer
Obtains a map of partition to tier size.
checkZeroErrorPartitions() - Method in class kafka.tier.compatibility.JmxMetricsAnalyzer
Verifies the cluster state.
collectJmxMetrics(AdminClient, String, String, String, String, boolean, int, int, int, boolean) - Static method in class kafka.tier.compatibility.TierTestUtils
Collects JMX metrics from all brokers in the cluster for the specified duration, and returns the collected metrics to the caller.
createAdminClient(String) - Static method in class kafka.tier.compatibility.TierTestUtils
Creates an admin client.
createS3ObjectStoreConfig(Properties) - Static method in class kafka.tier.compatibility.ObjectStoreUtils
Given object store properties and broker properties, creates a S3 Tier Object Store configuration.
createTopic(AdminClient, String, int, long, long, int, int) - Static method in class kafka.tier.compatibility.TierTestUtils
Creates a topic using the provided bootstrap server & topic name and given topic configs.
CustomTextListener - Class in kafka.tier.compatibility
A listener that listens to changes in JUnit test runs and logs suitable formatted messages for the reader, as required by the tier object store compatibility checker test suite.
CustomTextListener(JUnitSystem) - Constructor for class kafka.tier.compatibility.CustomTextListener
 
CustomTextListener(PrintStream) - Constructor for class kafka.tier.compatibility.CustomTextListener
 

D

debug(String) - Method in class kafka.tier.compatibility.Logger
 
deleteTopic(AdminClient, String) - Static method in class kafka.tier.compatibility.TierTestUtils
Deletes the earlier created topic on the bootstrap server (if the topic exists).

E

elapsedTimeAsString(long) - Method in class kafka.tier.compatibility.CustomTextListener
Returns the formatted string of the elapsed time.
error(String) - Method in class kafka.tier.compatibility.Logger
 

G

get() - Method in class kafka.tier.compatibility.RemoteTierObjectStoreSupplier
Creates a new TierObjectStore based on earlier set properties.
getConsumptionInfo() - Method in class kafka.tier.compatibility.ProducerConsumerTracker
 
getNumberOfConsumedMessages() - Method in class kafka.tier.compatibility.ProducerConsumerTracker
 
getNumberOfMessagesToBeConsumed() - Method in class kafka.tier.compatibility.ProducerConsumerTracker
 
getNumberOfProducedMessages() - Method in class kafka.tier.compatibility.ProducerConsumerTracker
 
getProducerTimestampOffsetMap() - Method in class kafka.tier.compatibility.ProducerConsumerTracker
 

I

info(String) - Method in class kafka.tier.compatibility.Logger
 
infoOut(String) - Method in class kafka.tier.compatibility.Logger
 
init(TierTestConfig) - Static method in class kafka.tier.compatibility.TieringFunctionalityTest
 

J

JmxMetricsAnalyzer - Class in kafka.tier.compatibility
Helper class which analyzes JMX metrics, given a metrics filename.
JmxMetricsAnalyzer(Map<Integer, String>, AdminClient, String, int, boolean) - Constructor for class kafka.tier.compatibility.JmxMetricsAnalyzer
 

K

kafka.tier.compatibility - package kafka.tier.compatibility
 

L

Logger - Class in kafka.tier.compatibility
 
Logger(boolean) - Constructor for class kafka.tier.compatibility.Logger
 
Logger() - Constructor for class kafka.tier.compatibility.Logger
 

M

main(String[]) - Static method in class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 
maxOffset() - Method in class kafka.tier.compatibility.ProducerConsumerTracker.PerPartitionConsumptionInfo
 

O

objectDeletionsCompleted(Properties, String, int, int) - Static method in class kafka.tier.compatibility.TierTestUtils
Verifies data retention workflow by repeatedly querying S3 for list of object.
ObjectStoreUtils - Class in kafka.tier.compatibility
 
ObjectStoreUtils() - Constructor for class kafka.tier.compatibility.ObjectStoreUtils
 

P

PerPartitionConsumptionInfo(long, long) - Constructor for class kafka.tier.compatibility.ProducerConsumerTracker.PerPartitionConsumptionInfo
 
PerPartitionConsumptionInfo() - Constructor for class kafka.tier.compatibility.ProducerConsumerTracker.PerPartitionConsumptionInfo
 
printFailure(Failure, String) - Method in class kafka.tier.compatibility.CustomTextListener
 
printFailures(Result) - Method in class kafka.tier.compatibility.CustomTextListener
 
printFooter(Result) - Method in class kafka.tier.compatibility.CustomTextListener
 
printHeader(long) - Method in class kafka.tier.compatibility.CustomTextListener
 
ProducerConsumerTracker - Class in kafka.tier.compatibility
This class keeps track of what data has been produced & consumed.
ProducerConsumerTracker() - Constructor for class kafka.tier.compatibility.ProducerConsumerTracker
 
ProducerConsumerTracker.PerPartitionConsumptionInfo - Class in kafka.tier.compatibility
 

R

recordConsumedMessageBatch(ConsumerRecords<String, String>) - Method in class kafka.tier.compatibility.ProducerConsumerTracker
Records a batch of consumed messages and validates that it is in either the tracker or the outstandingMessages set.
recordOutstandingMessage(String) - Method in class kafka.tier.compatibility.ProducerConsumerTracker
Records an enqueued message.
recordProducedMessage(String, RecordMetadata) - Method in class kafka.tier.compatibility.ProducerConsumerTracker
Records a successfully produced message.
RemoteTierObjectStoreSupplier - Class in kafka.tier.compatibility
A supplier which returns a TierObjectStore from given properties passed by a Namespace from argparse.
RemoteTierObjectStoreSupplier(TierTestConfig) - Constructor for class kafka.tier.compatibility.RemoteTierObjectStoreSupplier
Given a Namespace from argparse, populates a Properties object to initialize a TierObjectStore.
removeOutstandingMessage(String) - Method in class kafka.tier.compatibility.ProducerConsumerTracker
Removes an enqueued message.

S

SELECTED_COMMAND - Static variable in class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 
status(boolean) - Method in class kafka.tier.compatibility.ProducerConsumerTracker
 
stopwatch - Variable in class kafka.tier.compatibility.TieringFunctionalityTest
 

T

TEST_OBJECT_STORE - Static variable in class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 
TEST_TIERED_STORAGE_CORRECTNESS - Static variable in class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 
TEST_TIERED_STORAGE_FETCH - Static variable in class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 
testFailure(Failure) - Method in class kafka.tier.compatibility.CustomTextListener
 
testIgnored(Description) - Method in class kafka.tier.compatibility.CustomTextListener
 
testRunFinished(Result) - Method in class kafka.tier.compatibility.CustomTextListener
 
testStarted(Description) - Method in class kafka.tier.compatibility.CustomTextListener
 
tieringCompleted() - Method in class kafka.tier.compatibility.JmxMetricsAnalyzer
Determines whether tiering has completed by checking the following: 1.
TieringFunctionalityTest - Class in kafka.tier.compatibility
 
TieringFunctionalityTest() - Constructor for class kafka.tier.compatibility.TieringFunctionalityTest
 
tieringStarted() - Method in class kafka.tier.compatibility.JmxMetricsAnalyzer
Checks whether tiering has started.
TierObjectStoreCompatibilityChecker - Class in kafka.tier.compatibility
This class provides a CLI interface that lets the user run a suite of tests.
TierObjectStoreCompatibilityChecker() - Constructor for class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 
tierRoundtripTest() - Method in class kafka.tier.compatibility.TieringFunctionalityTest
Tests basic tiering data workflow.
TierTestUtils - Class in kafka.tier.compatibility
Common utility functions for use within the tiered storage tests of the object store compatibility checker.
timestampToOffsetMap() - Method in class kafka.tier.compatibility.ProducerConsumerTracker.PerPartitionConsumptionInfo
 

U

update(long, long) - Method in class kafka.tier.compatibility.ProducerConsumerTracker.PerPartitionConsumptionInfo
 

V

VALIDATE_CONFIGURATION - Static variable in class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 

W

WAIT_TIERING_COMPLETION - Static variable in class kafka.tier.compatibility.TierObjectStoreCompatibilityChecker
 
warn(String) - Method in class kafka.tier.compatibility.Logger
 
C D E G I J K L M O P R S T U V W 
Skip navigation links