public class JmxMetricsAnalyzer extends Object
Constructor and Description |
---|
JmxMetricsAnalyzer(Map<Integer,String> metricsFilenames,
org.apache.kafka.clients.admin.AdminClient adminClient,
String topic,
int numPartitions,
boolean debug) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkBytesFetchedFromLocalLog(int thresholdBytes)
Checks that the number of bytes fetched from a local log is within
the given threshold
|
Map<Integer,Long> |
checkTierSize()
Obtains a map of partition to tier size.
|
boolean |
checkZeroErrorPartitions()
Verifies the cluster state.
|
boolean |
tieringCompleted()
Determines whether tiering has completed by checking the following:
1.
|
boolean |
tieringStarted()
Checks whether tiering has started.
|
public JmxMetricsAnalyzer(Map<Integer,String> metricsFilenames, org.apache.kafka.clients.admin.AdminClient adminClient, String topic, int numPartitions, boolean debug) throws IOException
IOException
public boolean checkZeroErrorPartitions()
public boolean checkBytesFetchedFromLocalLog(int thresholdBytes)
public boolean tieringCompleted() throws ExecutionException, InterruptedException
public boolean tieringStarted()