- 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
-