public class RestoreMetricsUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
KAFKA_CLUSTER_ID |
static String |
KAFKA_NODE_ID |
Constructor and Description |
---|
RestoreMetricsUtil() |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.metrics.Metrics |
initializeMetrics(kafka.server.KafkaConfig config,
org.apache.kafka.common.utils.Time time,
String clusterId) |
public static final String KAFKA_CLUSTER_ID
public static final String KAFKA_NODE_ID
public static org.apache.kafka.common.metrics.Metrics initializeMetrics(kafka.server.KafkaConfig config, org.apache.kafka.common.utils.Time time, String clusterId)