public class Utils extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CONNECT_GROUP_ID |
static String |
CONNECT_KAFKA_CLUSTER_ID |
static String |
KAFKA_BROKER_ID |
static String |
KAFKA_BROKER_ROLE |
static String |
KAFKA_CELL_ID |
static String |
KAFKA_CLUSTER_ID |
static String |
KAFKA_CONTROLLER_ROLE |
static String |
KAFKA_NODE_ID |
static String |
KAFKA_PROCESS_ROLES |
static String |
LABEL_CLUSTER_ID |
static String |
RESOURCE_LABEL_CLUSTER_ID |
Constructor and Description |
---|
Utils() |
Modifier and Type | Method and Description |
---|---|
static ResourceBuilderFacade |
buildResourceFromAllLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext,
String id) |
static ResourceBuilderFacade |
buildResourceFromLabels(org.apache.kafka.common.metrics.MetricsContext metricsContext)
Build a
Resource from tags in the MetricsContext metadata. |
static ResourceBuilderFacade |
buildResourceFromLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext,
String id) |
static io.confluent.telemetry.api.events.Event |
configEvent(Map<String,?> cfg,
Predicate<String> configPredicate,
io.opentelemetry.proto.resource.v1.Resource res,
Provider provider,
String eventType) |
static Predicate<String> |
configPredicate(String regexString) |
static Map<String,String> |
getNonResourceLabels(Map<String,String> metricsCtxMetadata) |
static Map<String,String> |
getResourceLabels(Map<String,String> metricsCtxMetadata)
Extract the resource labels from the metrics context metadata and remove metrics context
prefix.
|
static boolean |
notEmptyString(Map<String,?> m,
String key)
Validate that the map contains the key and the key is a non-empty string
|
static boolean |
validateRequiredLabels(Map<String,String> metadata)
Validate that the
MetricsContext metadata has tags for - _namespace - type - version -
cluster id |
static boolean |
validateRequiredResourceLabels(Map<String,String> metadata) |
public static final String LABEL_CLUSTER_ID
public static final String RESOURCE_LABEL_CLUSTER_ID
public static final String KAFKA_BROKER_ID
public static final String KAFKA_NODE_ID
public static final String KAFKA_CLUSTER_ID
public static final String KAFKA_CELL_ID
public static final String KAFKA_PROCESS_ROLES
public static final String KAFKA_CONTROLLER_ROLE
public static final String KAFKA_BROKER_ROLE
public static final String CONNECT_KAFKA_CLUSTER_ID
public static final String CONNECT_GROUP_ID
public static boolean notEmptyString(Map<String,?> m, String key)
public static Map<String,String> getResourceLabels(Map<String,String> metricsCtxMetadata)
public static Map<String,String> getNonResourceLabels(Map<String,String> metricsCtxMetadata)
public static ResourceBuilderFacade buildResourceFromLabels(org.apache.kafka.common.metrics.MetricsContext metricsContext)
Resource
from tags in the MetricsContext
metadata.public static ResourceBuilderFacade buildResourceFromLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext, String id)
public static ResourceBuilderFacade buildResourceFromAllLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext, String id)
public static boolean validateRequiredLabels(Map<String,String> metadata)
MetricsContext
metadata has tags for - _namespace - type - version -
cluster idpublic static boolean validateRequiredResourceLabels(Map<String,String> metadata)