Kafka Connect Connector Sink Task Metrics Metrics

In addition to these base metrics, many aggregate metrics are available. If an entity type has parents defined, you can formulate all possible aggregate metrics using the formula base_metric_across_parents.

In addition, metrics for aggregate totals can be formed by adding the prefix total_ to the front of the metric name.

Use the type-ahead feature in the Cloudera Manager chart browser to find the exact aggregate metric name, in case the plural form does not end in "s".

For example, the following metric names may be valid for Kafka Connect Connector Sink Task Metrics:

• kafka_connect_connector_sink_task_metrics_partition_count_across_clusters
• total_kafka_connect_connector_sink_task_metrics_partition_count_across_clusters

Some metrics, such as alerts_rate, apply to nearly every metric context. Others only apply to a certain service or role.

Metric Name	Description	Unit	Parents	CDH Version
kafka_connect_connector_sink_task_metrics_partition_count	The number of topic partitions assigned to this task belonging to the named sink connector in this worker.	message.units.connectors	cluster, kafka, kafka-kafka_connect, rack	CDH 5, CDH 6, CDH 7
kafka_connect_connector_sink_task_metrics_put_batch_avg_time_ms	The average time taken by this task to put a batch of sinks records.	message.units.milliseconds	cluster, kafka, kafka-kafka_connect, rack	CDH 5, CDH 6, CDH 7
kafka_connect_connector_sink_task_metrics_sink_record_lag_max	The maximum lag in terms of number of records that the sink task is behind the consumer's position for any topic partitions.	message.units.connectors	cluster, kafka, kafka-kafka_connect, rack	CDH 5, CDH 6, CDH 7
kafka_connect_connector_sink_task_metrics_sink_record_send_rate	The average per-second number of records output from the transformations and sent/put to this task belonging to the named sink connector in this worker. This is after transformations are applied and excludes any records filtered out by the transformations.	message.units.connectors per second	cluster, kafka, kafka-kafka_connect, rack	CDH 5, CDH 6, CDH 7