Class Utils

java.lang.Object

io.confluent.telemetry.provider.Utils

public class Utils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONNECT_GROUP_ID
static final String	CONNECT_KAFKA_CLUSTER_ID
static final String	CONNECT_WORKER_ID
static final String	KAFKA_BROKER_ID
static final String	KAFKA_BROKER_ROLE
static final String	KAFKA_CELL_ID
static final String	KAFKA_CLUSTER_ID
static final String	KAFKA_CONTROLLER_ROLE
static final String	KAFKA_NODE_ID
static final String	KAFKA_PROCESS_ROLES
static final String	LABEL_CLUSTER_ID
static final String	LABEL_RESOURCE_ID
static final String	RESOURCE_LABEL_CLUSTER_ID

Constructor Summary

Constructors

Constructor	Description
Utils()

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LABEL_CLUSTER_ID

public static final String LABEL_CLUSTER_ID

See Also:

• Constant Field Values

RESOURCE_LABEL_CLUSTER_ID

public static final String RESOURCE_LABEL_CLUSTER_ID

See Also:

• Constant Field Values

LABEL_RESOURCE_ID

public static final String LABEL_RESOURCE_ID

See Also:

• Constant Field Values

KAFKA_BROKER_ID

public static final String KAFKA_BROKER_ID

See Also:

• Constant Field Values

KAFKA_NODE_ID

public static final String KAFKA_NODE_ID

See Also:

• Constant Field Values

KAFKA_CLUSTER_ID

public static final String KAFKA_CLUSTER_ID

See Also:

• Constant Field Values

KAFKA_CELL_ID

public static final String KAFKA_CELL_ID

See Also:

• Constant Field Values

KAFKA_PROCESS_ROLES

public static final String KAFKA_PROCESS_ROLES

See Also:

• Constant Field Values

KAFKA_CONTROLLER_ROLE

public static final String KAFKA_CONTROLLER_ROLE

See Also:

• Constant Field Values

KAFKA_BROKER_ROLE

public static final String KAFKA_BROKER_ROLE

See Also:

• Constant Field Values

CONNECT_KAFKA_CLUSTER_ID

public static final String CONNECT_KAFKA_CLUSTER_ID

See Also:

• Constant Field Values

CONNECT_GROUP_ID

public static final String CONNECT_GROUP_ID

See Also:

• Constant Field Values

CONNECT_WORKER_ID

public static final String CONNECT_WORKER_ID

See Also:

• Constant Field Values

Constructor Details

Utils

public Utils()

Method Details

notEmptyString

public static boolean notEmptyString(Map<String,?> m,
 String key)

Validate that the map contains the key and the key is a non-empty string

Returns:

true if key is valid.

getResourceLabels

public static Map<String,String> getResourceLabels(Map<String,String> metricsCtxMetadata)

Extract the resource labels from the metrics context metadata and remove metrics context prefix.

Returns:

a map of cleaned up labels.

getNonResourceLabels

public static Map<String,String> getNonResourceLabels(Map<String,String> metricsCtxMetadata)

buildResourceFromLabels

public static ResourceBuilderFacade buildResourceFromLabels(org.apache.kafka.common.metrics.MetricsContext metricsContext)

Build a Resource from tags in the MetricsContext metadata.

Returns:

buildResourceFromLabelsWithId

public static ResourceBuilderFacade buildResourceFromLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext,
 String id)

buildResourceFromAllLabelsWithId

public static ResourceBuilderFacade buildResourceFromAllLabelsWithId(org.apache.kafka.common.metrics.MetricsContext metricsContext,
 String id)

validateRequiredLabels

public static boolean validateRequiredLabels(Map<String,String> metadata)

Validate that the MetricsContext metadata has tags for - _namespace - type - version - cluster id

Returns:

true if valid tags exist, false otherwise.

validateRequiredResourceLabels

public static boolean validateRequiredResourceLabels(Map<String,String> metadata)

configPredicate

public static Predicate<String> configPredicate(String regexString)

configEvent

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