Confluent Platform インテグレーションのメトリクス

Confluent Platform の監視に使う Datadog の公式インテグレーションです。収集するメトリクスは 447 件あります。

公式の紹介文 (英語)

Monitor Confluent Platform components.

種別の内訳

  • gauge (その時点の値): 447 件

メトリクスの一覧

説明は公式の定義の英文をそのまま載せています。

メトリクス種別単位
confluent.kafka.cluster.partition.under_min_isrNumber of partitions whose in-sync replicas count is less than minIsr. These partitions will be unavailable to producers who use acks=all.gauge-
confluent.kafka.connect.connect_metrics.failed_authentication_rateFailed authentication rategauge-
confluent.kafka.connect.connect_metrics.failed_authentication_totalfailed authentication totalgauge-
confluent.kafka.connect.connect_metrics.incoming_byte_rateIncoming byte rategaugebyte
confluent.kafka.connect.connect_metrics.outgoing_byte_rateOutgoing byte_rategaugebyte
confluent.kafka.connect.connect_metrics.successful_authentication_rateSuccessful authentication rategauge-
confluent.kafka.connect.connect_metrics.successful_authentication_totalsuccessful authentication totalgauge-
confluent.kafka.connect.connector_metrics.statusStatus of connectorgauge-
confluent.kafka.connect.connector_task.batch_size_avgThe average size of the batches processed by the connector.gauge-
confluent.kafka.connect.connector_task.batch_size_maxThe maximum size of the batches processed by the connector.gauge-
confluent.kafka.connect.connector_task.offset_commit_avg_time_msThe average time in milliseconds taken by this task to commit offsets.gaugemillisecond
confluent.kafka.connect.connector_task.offset_commit_failure_percentageThe average percentage of this task's offset commit attempts that failed.gaugepercent
confluent.kafka.connect.connector_task.offset_commit_max_time_msThe maximum time in milliseconds taken by this task to commit offsets.gaugemillisecond
confluent.kafka.connect.connector_task.offset_commit_success_percentageThe average percentage of this task's offset commit attempts that succeeded.gaugepercent
confluent.kafka.connect.connector_task.pause_ratioThe fraction of time this task has spent in the pause state.gaugefraction
confluent.kafka.connect.connector_task.running_ratioThe fraction of time this task has spent in the running state.gaugefraction
confluent.kafka.connect.sink_task.offset_commit_completion_rateThe average per-second number of offset commit completions that were completed successfully.gaugecommit/second
confluent.kafka.connect.sink_task.offset_commit_completion_totalThe total number of offset commit completions that were completed successfully.gaugecommit
confluent.kafka.connect.sink_task.offset_commit_seq_noThe current sequence number for offset commits.gauge-
confluent.kafka.connect.sink_task.offset_commit_skip_rateThe average per-second number of offset commit completions that were received too late and skipped/ignored.gaugecommit/second
confluent.kafka.connect.sink_task.offset_commit_skip_totalThe total number of offset commit completions that were received too late and skipped/ignored.gaugecommit
confluent.kafka.connect.sink_task.partition_countThe number of topic partitions assigned to this task belonging to the named sink connector in this worker.gauge-
confluent.kafka.connect.sink_task.put_batch_avg_time_msThe average time taken by this task to put a batch of sinks records.gaugemillisecond
confluent.kafka.connect.sink_task.put_batch_max_time_msThe maximum time taken by this task to put a batch of sinks records.gaugemillisecond
confluent.kafka.connect.sink_task.sink_record_active_countThe number of records that have been read from Kafka but not yet completely committed/flushed/acknowledged by the sink task.gaugerecord
confluent.kafka.connect.sink_task.sink_record_active_count_avgThe average number of records that have been read from Kafka but not yet completely committed/flushed/acknowledged by the sink task.gaugerecord
confluent.kafka.connect.sink_task.sink_record_active_count_maxThe maximum number of records that have been read from Kafka but not yet completely committed/flushed/acknowledged by the sink task.gaugerecord
confluent.kafka.connect.sink_task.sink_record_lag_maxThe maximum lag in terms of number of records that the sink task is behind the consumer's position for any topic partitions.gaugerecord
confluent.kafka.connect.sink_task.sink_record_read_rateThe average per-second number of records read from Kafka for this task belonging to the named sink connector in this worker. This is before transformations are applied.gaugerecord/second
confluent.kafka.connect.sink_task.sink_record_read_totalThe total number of records read from Kafka by this task belonging to the named sink connector in this worker, since the task was last restarted.gaugerecord
confluent.kafka.connect.sink_task.sink_record_send_rateThe 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.gaugerecord/second
confluent.kafka.connect.sink_task.sink_record_send_totalThe total number of records output from the transformations and sent/put to this task belonging to the named sink connector in this worker, since the task was last restarted.gaugerecord
confluent.kafka.connect.source_task.poll_batch_avg_time_msThe average time in milliseconds taken by this task to poll for a batch of source records.gaugemillisecond
confluent.kafka.connect.source_task.poll_batch_max_time_msThe maximum time in milliseconds taken by this task to poll for a batch of source records.gaugemillisecond
confluent.kafka.connect.source_task.source_record_active_countThe number of records that have been produced by this task but not yet completely written to Kafka.gaugerecord
confluent.kafka.connect.source_task.source_record_active_count_avgThe average number of records that have been produced by this task but not yet completely written to Kafka.gaugerecord
confluent.kafka.connect.source_task.source_record_active_count_maxThe maximum number of records that have been produced by this task but not yet completely written to Kafka.gaugerecord
confluent.kafka.connect.source_task.source_record_poll_rateThe average per-second number of records produced/polled (before transformation) by this task belonging to the named source connector in this worker.gaugerecord/second
confluent.kafka.connect.source_task.source_record_poll_totalThe total number of records produced/polled (before transformation) by this task belonging to the named source connector in this worker.gaugerecord
confluent.kafka.connect.source_task.source_record_write_rateThe average per-second number of records output from the transformations and written to Kafka for this task belonging to the named source connector in this worker. This is after transformations are applied and excludes any records filtered out by the transformations.gaugerecord/second
confluent.kafka.connect.source_task.source_record_write_totalThe number of records output from the transformations and written to Kafka for this task belonging to the named source connector in this worker, since the task was last restarted.gaugerecord
confluent.kafka.connect.task_error.deadletterqueue_produce_failuresThe number of failed writes to the dead letter queue.gauge-
confluent.kafka.connect.task_error.deadletterqueue_produce_requestsThe number of attempted writes to the dead letter queue.gauge-
confluent.kafka.connect.task_error.last_error_timestampThe epoch timestamp when this task last encountered an error in millisecond.gaugemillisecond
confluent.kafka.connect.task_error.total_errors_loggedThe number of errors that were logged.gaugeerror
confluent.kafka.connect.task_error.total_record_errorsThe number of record processing errors in this task.gaugerecord
confluent.kafka.connect.task_error.total_record_failuresThe number of record processing failures in this task.gaugerecord
confluent.kafka.connect.task_error.total_records_skippedThe number of records skipped due to errors.gaugerecord
confluent.kafka.connect.task_error.total_retriesThe number of operations retried.gaugeoperation
confluent.kafka.connect.worker.connector_countThe number of connectors run in this worker.gaugerecord
confluent.kafka.connect.worker.connector_destroyed_task_countThe number of destroyed tasks of the connector on the worker.gaugetask
confluent.kafka.connect.worker.connector_failed_task_countThe number of failed tasks of the connector on the worker.gaugetask
confluent.kafka.connect.worker.connector_paused_task_countThe number of paused tasks of the connector on the worker.gaugetask
confluent.kafka.connect.worker.connector_running_task_countThe number of running tasks of the connector on the worker.gaugetask
confluent.kafka.connect.worker.connector_startup_attempts_totalThe total number of connector startups that this worker has attempted.gauge-
confluent.kafka.connect.worker.connector_startup_failure_percentageThe average percentage of this worker's connectors starts that failed.gaugepercent
confluent.kafka.connect.worker.connector_startup_failure_totalThe total number of connector starts that failed.gauge-
confluent.kafka.connect.worker.connector_startup_success_percentageThe average percentage of this worker's connectors starts that succeeded.gaugepercent
confluent.kafka.connect.worker.connector_startup_success_totalThe total number of connector starts that succeeded.gauge-
confluent.kafka.connect.worker.connector_total_task_countThe number of tasks of the connector on the worker.gaugetask
confluent.kafka.connect.worker.connector_unassigned_task_countThe number of unassigned tasks of the connector on the worker.gaugetask
confluent.kafka.connect.worker.task_countThe number of tasks run in this worker.gaugetask
confluent.kafka.connect.worker.task_startup_attempts_totalThe total number of task startups that this worker has attempted.gauge-
confluent.kafka.connect.worker.task_startup_failure_percentageThe average percentage of this worker's tasks starts that failed.gaugepercent
confluent.kafka.connect.worker.task_startup_failure_totalThe total number of task starts that failed.gauge-
confluent.kafka.connect.worker.task_startup_success_percentageThe average percentage of this worker's tasks starts that succeeded.gaugepercent
confluent.kafka.connect.worker.task_startup_success_totalThe total number of task starts that succeeded.gauge-
confluent.kafka.connect.worker_rebalance.completed_rebalances_totalThe total number of rebalances completed by this worker.gauge-
confluent.kafka.connect.worker_rebalance.epochThe epoch or generation number of this worker.gauge-
confluent.kafka.connect.worker_rebalance.rebalance_avg_time_msThe average time in milliseconds spent by this worker to rebalance.gaugemillisecond
confluent.kafka.connect.worker_rebalance.rebalance_max_time_msThe maximum time in milliseconds spent by this worker to rebalance.gaugemillisecond
confluent.kafka.connect.worker_rebalance.rebalancingWhether this worker is currently rebalancing.gauge-
confluent.kafka.connect.worker_rebalance.time_since_last_rebalance_msThe time in milliseconds since this worker completed the most recent rebalance.gaugemillisecond
confluent.kafka.consumer.bytes_consumed_rateIndicates throughput of Replicator reading events from origin cluster.gaugebyte
confluent.kafka.consumer.connection_countThe current number of active connections on the consumer.gaugeconnection
confluent.kafka.consumer.fetch.bytes_consumed_rateThe average number of bytes consumed per second.gaugebyte/second
confluent.kafka.consumer.fetch.fetch_latency_avgThe average time taken for a fetch request.gaugemillisecond
confluent.kafka.consumer.fetch.fetch_latency_maxThe max time taken for a fetch request.gaugemillisecond
confluent.kafka.consumer.fetch.fetch_rateThe number of fetch requests per second.gaugerequest/second
confluent.kafka.consumer.fetch.fetch_size_avgThe average number of bytes fetched per fetch request.gaugebyte
confluent.kafka.consumer.fetch.fetch_size_maxThe maximum number of bytes fetched per fetch request.gaugebyte
confluent.kafka.consumer.fetch.fetch_throttle_time_avgThe average throttle time in ms. When quotas are enabled, the broker may delay fetch requests in order to throttle a consumer which has exceeded its limit. This metric indicates how throttling time has been added to fetch requests on average.gaugemillisecond
confluent.kafka.consumer.fetch.fetch_throttle_time_maxThe maximum throttle time in ms.gaugemillisecond
confluent.kafka.consumer.fetch.records_consumed_rateThe average number of records consumed per second.gaugerecord/second
confluent.kafka.consumer.fetch.records_lag_maxThe maximum lag in terms of number of records for any partition in this window. An increasing value over time is your best indication that the consumer group is not keeping up with the producers.gaugerecord
confluent.kafka.consumer.fetch.records_per_request_avgThe average number of records in each request.gaugerecord
confluent.kafka.consumer.fetch_rateThe number of fetches per second.gaugerequest/second
confluent.kafka.consumer.fetch_size_avgThe average number of bytes fetched per requestgaugebyte
confluent.kafka.consumer.fetch_size_maxThe maximum number of bytes fetched per request.gaugebyte
confluent.kafka.consumer.fetch_throttle_time_avgFetch requests may be throttled to meet quotas configured on the origin cluster. If this average is non-zero, it indicates that the origin brokers are slowing the consumer down and the quotas configuration should be reviewed. For more information on quotas see Enforcing Client Quotasgaugemillisecond
confluent.kafka.consumer.fetch_throttle_time_maxFetch requests may be throttled to meet quotas configured on the origin cluster. If this maximum is non-zero, it indicates that the origin brokers are slowing the consumer down and the quotas configuration should be reviewed. For more information on quotas see Enforcing Client Quotasgaugemillisecond
confluent.kafka.consumer.fetch_topic.bytes_consumed_rateThe average number of bytes consumed per second for a specific topic.gaugebyte/second
confluent.kafka.consumer.fetch_topic.fetch_size_avgThe average number of bytes fetched per request for a specific topic.gaugebyte
confluent.kafka.consumer.fetch_topic.fetch_size_maxThe maximum number of bytes fetched per request for a specific topic.gaugebyte
confluent.kafka.consumer.fetch_topic.records_consumed_rateThe average number of records consumed per second for a specific topic.gaugerecord/second
confluent.kafka.consumer.fetch_topic.records_per_request_avgThe average number of records in each request for a specific topic.gaugerecord
confluent.kafka.consumer.group.assigned_partitionsThe number of partitions currently assigned to this consumer.gaugeunit
confluent.kafka.consumer.group.commit_latency_avgThe average time taken for a commit request.gaugemillisecond
confluent.kafka.consumer.group.commit_latency_maxThe max time taken for a commit request.gaugemillisecond
confluent.kafka.consumer.group.commit_rateThe number of commit calls per secondgaugecommit/second
confluent.kafka.consumer.group.heartbeat_rateThe average number of heartbeats per second.gaugeoperation/second
confluent.kafka.consumer.group.heartbeat_response_time_maxThe max time taken to receive a response to a heartbeat request.gaugemillisecond
confluent.kafka.consumer.group.join_rateThe number of group joins per second. Group joining is the first phase of the rebalance protocol. A large value indicates that the consumer group is unstable and will likely be coupled with increased lag.gaugeoperation/second
confluent.kafka.consumer.group.join_time_avgThe average time taken for a group rejoin.gaugemillisecond
confluent.kafka.consumer.group.join_time_maxThe max time taken for a group rejoin. This value should not get much higher than the configured session timeout for the consumer.gaugemillisecond
confluent.kafka.consumer.group.last_heartbeat_seconds_agoThe number of seconds since the last controller heartbeat.gaugesecond
confluent.kafka.consumer.group.sync_rateThe number of group syncs per second. Group synchronization is the second and last phase of the rebalance protocol.gaugeoperation/second
confluent.kafka.consumer.group.sync_time_avgThe average time taken for a group sync.gaugemillisecond
confluent.kafka.consumer.group.sync_time_maxThe max time taken for a group sync.gaugemillisecond
confluent.kafka.consumer.io_ratioThe fraction of time the consumer I/O thread spent doing I/Ogaugefraction
confluent.kafka.consumer.io_wait_ratioThe fraction of time the consumer I/O thread spent waitinggaugefraction
confluent.kafka.consumer.network_io_rateThe number of network operations (reads or writes) on all consumer connections per secondgaugeconnection/second
confluent.kafka.consumer.records_lag_maxThe maximum lag in terms of number of records for any partition. An increasing value over time indicates that Replicator is not keeping up with the rate at which events are written to the origin cluster.gaugerecord
confluent.kafka.consumer.request_latency_avgThe average consumer request latency in msgaugemillisecond
confluent.kafka.consumer.request_rateThe number of requests sent per second by a consumergaugerequest/second
confluent.kafka.consumer.response_rateThe number of responses received per second by a consumergaugeresponse/second
confluent.kafka.controller.active_controller_countNumber of active controllers in the cluster. Alert if the aggregated sum across all brokers in the cluster is anything other than 1 because there should be exactly one controller per cluster.gauge-
confluent.kafka.controller.global_partition_countglobal partition countgauge-
confluent.kafka.controller.global_topic_countglobal topic countgauge-
confluent.kafka.controller.global_under_min_isr_partition_countunder min isr countgauge-
confluent.kafka.controller.leader_election_rate_and_time_ms.avgLeader election rate avg.gaugemillisecond
confluent.kafka.controller.leader_election_rate_and_time_ms.rateLeader election rate.gaugemillisecond
confluent.kafka.controller.offline_partitions_countNumber of partitions that don't have an active leader and are hence not writable or readable. Alert if value is greater than 0.gauge-
confluent.kafka.controller.preferred_replica_imbalance_countPreferred Replica Imbalance Countgauge-
confluent.kafka.controller.unclean_leader_elections_per_sec.avgUnclean leader election rate avg.gaugeunit/second
confluent.kafka.controller.unclean_leader_elections_per_sec.rateUnclean leader election rate.gaugeunit/second
confluent.kafka.log.log_flush_rate_and_time_ms.avgLog flush rate avg.gaugemillisecond
confluent.kafka.log.log_flush_rate_and_time_ms.rateLog flush rate.gaugemillisecond
confluent.kafka.log.sizelog size per topicgaugebyte
confluent.kafka.network.request.local_time_ms.50percentileTime the request is processed at the leader (50percentile).gaugemillisecond
confluent.kafka.network.request.local_time_ms.75percentileTime the request is processed at the leader (75percentile).gaugemillisecond
confluent.kafka.network.request.local_time_ms.95percentileTime the request is processed at the leader (95percentile).gaugemillisecond
confluent.kafka.network.request.local_time_ms.98percentileTime the request is processed at the leader (98percentile).gaugemillisecond
confluent.kafka.network.request.local_time_ms.999percentileTime the request is processed at the leader (999percentile).gaugemillisecond
confluent.kafka.network.request.local_time_ms.99percentileTime the request is processed at the leader (99percentile).gaugemillisecond
confluent.kafka.network.request.local_time_ms.avgTime the request is processed at the leader (avg).gaugemillisecond
confluent.kafka.network.request.local_time_ms.rateTime the request is processed at the leader (rate).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.50percentileTime the request waits for the follower. This is non-zero for produce requests when acks=all (50percentile).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.75percentileTime the request waits for the follower. This is non-zero for produce requests when acks=all (75percentile).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.95percentileTime the request waits for the follower. This is non-zero for produce requests when acks=all (95percentile).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.98percentileTime the request waits for the follower. This is non-zero for produce requests when acks=all (98percentile).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.999percentileTime the request waits for the follower. This is non-zero for produce requests when acks=all (999percentile).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.99percentileTime the request waits for the follower. This is non-zero for produce requests when acks=all (99percentile).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.avgTime the request waits for the follower. This is non-zero for produce requests when acks=all (avg).gaugemillisecond
confluent.kafka.network.request.remote_time_ms.rateTime the request waits for the follower. This is non-zero for produce requests when acks=all (rate).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.50percentileTime the request waits in the request queue (50percentile).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.75percentileTime the request waits in the request queue (75percentile).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.95percentileTime the request waits in the request queue (95percentile).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.98percentileTime the request waits in the request queue (98percentile).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.999percentileTime the request waits in the request queue (999percentile).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.99percentileTime the request waits in the request queue (99percentile).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.avgTime the request waits in the request queue (avg).gaugemillisecond
confluent.kafka.network.request.request_queue_time_ms.rateTime the request waits in the request queue (rate).gaugemillisecond
confluent.kafka.network.request.requests_per_sec.rateRequest rate.gaugerequest/second
confluent.kafka.network.request.response_queue_time_ms.50percentileTime the request waits in the response queue (50percentile).gaugemillisecond
confluent.kafka.network.request.response_queue_time_ms.75percentileTime the request waits in the response queue (75percentile).gaugemillisecond
confluent.kafka.network.request.response_queue_time_ms.95percentileTime the request waits in the response queue (95percentile).gaugemillisecond
confluent.kafka.network.request.response_queue_time_ms.98percentileTime the request waits in the response queue (98percentile).gaugemillisecond
confluent.kafka.network.request.response_queue_time_ms.999percentileTime the request waits in the response queue (999percentile).gaugemillisecond
confluent.kafka.network.request.response_queue_time_ms.99percentileTime the request waits in the response queue (99percentile).gaugemillisecond
confluent.kafka.network.request.response_queue_time_ms.avgTime the request waits in the response queue (avg).gaugemillisecond
confluent.kafka.network.request.response_queue_time_ms.rateTime the request waits in the response queue (rate).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.50percentileTime to send the response (50percentile).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.75percentileTime to send the response (75percentile).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.95percentileTime to send the response (95percentile).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.98percentileTime to send the response (98percentile).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.999percentileTime to send the response (999percentile).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.99percentileTime to send the response (99percentile).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.avgTime to send the response (avg).gaugemillisecond
confluent.kafka.network.request.response_send_time_ms.rateTime to send the response (rate).gaugemillisecond
confluent.kafka.network.request.total_time_ms.50percentileTotal time in ms to serve the specified request (50percentile).gaugemillisecond
confluent.kafka.network.request.total_time_ms.75percentileTotal time in ms to serve the specified request (75percentile).gaugemillisecond
confluent.kafka.network.request.total_time_ms.95percentileTotal time in ms to serve the specified request (95percentile).gaugemillisecond
confluent.kafka.network.request.total_time_ms.98percentileTotal time in ms to serve the specified request (98percentile).gaugemillisecond
confluent.kafka.network.request.total_time_ms.999percentileTotal time in ms to serve the specified request (999percentile).gaugemillisecond
confluent.kafka.network.request.total_time_ms.99percentileTotal time in ms to serve the specified request (99percentile).gaugemillisecond
confluent.kafka.network.request.total_time_ms.avgTotal time in ms to serve the specified request (avg).gaugemillisecond
confluent.kafka.network.request.total_time_ms.rateTotal time in ms to serve the specified request (rate).gaugemillisecond
confluent.kafka.network.request_channel.request_queue_sizeSize of the request queue. A congested request queue will not be able to process incoming or outgoing requestsgauge-
confluent.kafka.network.socket_server.network_processor_avg_idle_percentAverage fraction of time the network processor threads are idlegaugefraction
confluent.kafka.producer.batch_size_avgThe average number of bytes sent per partition per-request.gaugebyte
confluent.kafka.producer.batch_size_maxThe max number of bytes sent per partition per-request.gaugebyte
confluent.kafka.producer.bufferpool_wait_time_totalThe total time an appender waits for space allocation.gaugenanosecond
confluent.kafka.producer.connection_close_rateConnections closed per second in the window.gaugeconnection/second
confluent.kafka.producer.connection_countThe current number of active connections on the producer.gaugeconnection
confluent.kafka.producer.connection_creation_rateNew connections established per second in the window.gaugeconnection/second
confluent.kafka.producer.incoming_byte_rateThe average number of incoming bytes received per second from all servers.gaugebyte/second
confluent.kafka.producer.io_ratioThe fraction of time the producer I/O thread spent doing I/Ogaugefraction
confluent.kafka.producer.io_time_ns_avgThe average length of time for I/O per select call in nanoseconds.gaugenanosecond
confluent.kafka.producer.io_wait_ratioThe fraction of time the producer I/O thread spent waitinggaugefraction
confluent.kafka.producer.io_wait_time_ns_avgThe average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds.gaugenanosecond
confluent.kafka.producer.network_io_rateThe number of network operations (reads or writes) on all producer connections per secondgaugeoperation/second
confluent.kafka.producer.node.incoming_byte_rateThe average number of bytes received per second from the broker.gaugebyte/second
confluent.kafka.producer.node.outgoing_byte_rateThe average number of bytes sent per second to the broker.gaugebyte/second
confluent.kafka.producer.node.request_rateThe average number of requests sent per second to the broker.gaugerequest/second
confluent.kafka.producer.node.request_size_avgThe average size of all requests in the window for a broker.gaugerequest
confluent.kafka.producer.node.request_size_maxThe maximum size of any request sent in the window for a broker.gaugerequest
confluent.kafka.producer.node.response_rateThe average number of responses received per second from the broker.gaugeresponse/second
confluent.kafka.producer.outgoing_byte_rateThe number of outgoing bytes sent to all servers per secondgaugebyte/second
confluent.kafka.producer.produce_throttle_time_avgThe average time in ms a request was throttled by a brokergaugemillisecond
confluent.kafka.producer.produce_throttle_time_maxThe maximum time in ms a request was throttled by a brokergaugemillisecond
confluent.kafka.producer.record_error_rateThe average per-second number of record sends that resulted in errorsgaugerecord/second
confluent.kafka.producer.record_retry_rateThe average per-second number of retried record sendsgaugerecord/second
confluent.kafka.producer.request_latency_avgThe average producer request latency in msgaugemillisecond
confluent.kafka.producer.request_rateThe number of requests sent per second by a producergaugerequest/second
confluent.kafka.producer.response_rateThe number of responses received per second by the consumergaugeresponse/second
confluent.kafka.producer.select_rateNumber of times the I/O layer checked for new I/O to perform per second.gauge/second
confluent.kafka.producer.topic.byte_rateThe average number of bytes sent per second for a topic.gaugebyte/second
confluent.kafka.producer.topic.compression_rateThe average compression rate of record batches for a topic.gauge-
confluent.kafka.producer.topic.record_error_rateThe average per-second number of record sends that resulted in errors for a topic.gaugerecord/second
confluent.kafka.producer.topic.record_retry_rateThe average per-second number of retried record sends for a topic.gaugerecord/second
confluent.kafka.producer.topic.record_send_rateThe average number of records sent per second for a topic.gaugerecord/second
confluent.kafka.producer.waiting_threadsThe number of user threads blocked waiting for buffer memory to enqueue their recordsgaugethread
confluent.kafka.rest.jersey.brokers.list.request_error_rateThe average rate of failed brokers list HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.assign_v2.request_error_rateThe average rate of failed consumer assign v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.assignment_v2.request_error_rateThe average rate of failed consumer assignment v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.commit.request_error_rateThe average rate of failed consumer commit HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.commit_offsets_v2.request_error_rateThe average rate of failed consumer commit offsets v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.committed_offsets_v2.request_error_rateThe average rate of failed consumer committed offsets v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.create.request_error_rateThe average rate of failed consumer create HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.create_v2.request_error_rateThe average rate of failed consumer create v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.delete.request_error_rateThe average rate of failed consumer delete HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.delete_v2.request_error_rateThe average rate of failed consumer delete v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.records.read_avro_v2.request_error_rateThe average rate of failed consumer records read avro v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.records.read_binary_v2.request_error_rateThe average rate of failed consumer records read binary v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.records.read_json_v2.request_error_rateThe average rate of failed consumer records read json v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.records.read_jsonschema_v2.request_error_rateThe average rate of failed consumer topic read json HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.records.read_protobuf_v2.request_error_rateThe average rate of failed consumer topic read json HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.seek_to_beginning_v2.request_error_rateThe average rate of failed consumer seek to beginning v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.seek_to_end_v2.request_error_rateThe average rate of failed consumer seek to end v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.seek_to_offset_v2.request_error_rateThe average rate of failed consumer seek to offset v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.subscribe_v2.request_error_rateThe average rate of failed consumer subscribe v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.subscription_v2.request_error_rateThe average rate of failed consumer subscription v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.topic.read_avro.request_error_rateThe average rate of failed consumer topic read avro HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.topic.read_binary.request_error_rateThe average rate of failed consumer topic read binary HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.topic.read_json.request_error_rateThe average rate of failed consumer topic read json HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.consumer.unsubscribe_v2.request_error_rateThe average rate of failed consumer unsubscribe v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.consume_avro.request_error_rateThe average rate of failed partition consume avro HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.consume_binary.request_error_rateThe average rate of failed partition consume binary HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.consume_json.request_error_rateThe average rate of failed partition consume json HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.get.request_error_rateThe average rate of failed partition get HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.get_v2.request_error_rateThe average rate of failed partition get v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_avro.request_error_rateThe average rate of failed partition produce avro HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_avro_v2.request_error_rateThe average rate of failed partition produce avro v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_binary.request_error_rateThe average rate of failed partition produce binary HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_binary_v2.request_error_rateThe average rate of failed partition produce binary v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_json.request_error_rateThe average rate of failed partition produce json HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_json_v2.request_error_rateThe average rate of failed partition produce json v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_jsonschema_v2.request_error_rateThe average rate of failed partition produce json v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partition.produce_protobuf_v2.request_error_rateThe average rate of failed partition produce json v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partitions.list.request_error_rateThe average rate of failed partitions list HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.partitions.list_v2.request_error_rateThe average rate of failed partitions list v2 HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.request_error_rateThe average rate of failed HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.root.get.request_error_rateThe average rate of failed root get HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.root.get_v2.request_error_rateThe average rate of failed root get HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.root.post.request_error_rateThe average rate of failed root post HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.root.post_v2.request_error_rateThe average rate of failed root post HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.topic.get.request_error_rateThe average rate of failed topic get HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.topic.get_v2.request_error_rateThe average rate of failed topic get HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.topic.produce_avro.request_error_rateThe average rate of failed topic produce avro HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.topic.produce_binary.request_error_rateThe average rate of failed topic produce binary HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.topic.produce_json.request_error_rateThe average rate of failed topic produce json HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.topics.list.request_error_rateThe average rate of failed topics list HTTP requestsgaugerequest/second
confluent.kafka.rest.jersey.topics.list_v2.request_error_rateThe average rate of failed topics list HTTP requestsgaugerequest/second
confluent.kafka.rest.jetty.connections_activeTotal number of active TCP connections (REST).gaugeconnection
confluent.kafka.rest.jetty.connections_closed_rateThe average rate per second of closed TCP connections (REST).gaugeconnection/second
confluent.kafka.rest.jetty.connections_opened_rateThe average rate per second of opened TCP connections (REST).gaugeconnection/second
confluent.kafka.schema.registry.avro_schemas_createdschemas created avrogauge-
confluent.kafka.schema.registry.avro_schemas_deletedschemas deleted avrogauge-
confluent.kafka.schema.registry.jersey.brokers.list.request_error_rateThe average rate of failed brokers list operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.brokers.list_v2.request_error_rateThe average rate of failed brokers list operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.assign_v2.request_error_rateThe average rate of failed consumer assign v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.assignment_v2.request_error_rateThe average rate of failed consumer assignment v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.commit.request_error_rateThe average rate of failed consumer commit operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.commit_offsets_v2.request_error_rateThe average rate of failed consumer commit offsets v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.committed_offsets_v2.request_error_rateThe average rate of failed consumer committed offsets v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.create.request_error_rateThe average rate of failed consumer create operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.create_v2.request_error_rateThe average rate of failed consumer create v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.delete.request_error_rateThe average rate of failed consumer delete operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.delete_v2.request_error_rateThe average rate of failed consumer delete v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.records.read_avro_v2.request_error_rateThe average rate of failed consumer records read avro v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.records.read_binary_v2.request_error_rateThe average rate of failed consumer records read binary v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.records.read_json_v2.request_error_rateThe average rate of failed consumer records read json v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.seek_to_beginning_v2.request_error_rateThe average rate of failed consumer seek to beginning v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.seek_to_end_v2.request_error_rateThe average rate of failed consumer seek to end v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.seek_to_offset_v2.request_error_rateThe average rate of failed consumer seek to offset v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.subscribe_v2.request_error_rateThe average rate of failed consumer subscribe v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.subscription_v2.request_error_rateThe average rate of failed consumer subscription v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.topic.read_avro.request_error_rateThe average rate of failed consumer topic read avro operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.topic.read_binary.request_error_rateThe average rate of failed consumer topic read binary operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.topic.read_json.request_error_rateThe average rate of failed consumer topic read json operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.consumer.unsubscribe_v2.request_error_rateThe average rate of failed consumer unsubscribe v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.consume_avro.request_error_rateThe average rate of failed partition consume avro operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.consume_binary.request_error_rateThe average rate of failed partition consume binary operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.consume_json.request_error_rateThe average rate of failed partition consume json operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.get.request_error_rateThe average rate of failed partition get operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.get_v2.request_error_rateThe average rate of failed partition get v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.produce_avro.request_error_rateThe average rate of failed partition produce avro operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.produce_avro_v2.request_error_rateThe average rate of failed partition produce avro v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.produce_binary.request_error_rateThe average rate of failed partition produce binary operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.produce_binary_v2.request_error_rateThe average rate of failed partition produce binary v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.produce_json.request_error_rateThe average rate of failed partition produce json operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partition.produce_json_v2.request_error_rateThe average rate of failed partition produce json v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partitions.list.request_error_rateThe average rate of failed partitions list operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.partitions.list_v2.request_error_rateThe average rate of failed partitions list v2 operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.request_error_rateThe average rate of failed operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.root.get.request_error_rateThe average rate of failed root get operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.root.post.request_error_rateThe average rate of failed root post operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.topic.get.request_error_rateThe average rate of failed topic get operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.topic.produce_avro.request_error_rateThe average rate of failed topic produce avro operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.topic.produce_binary.request_error_rateThe average rate of failed topic produce binary operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.topic.produce_json.request_error_rateThe average rate of failed topic produce json operationsgaugerequest/second
confluent.kafka.schema.registry.jersey.topics.list.request_error_rateThe average rate of failed topics list operationsgaugerequest/second
confluent.kafka.schema.registry.jetty.connections_activeTotal number of active TCP connections (Schema registry).gaugeconnection
confluent.kafka.schema.registry.jetty.connections_closed_rateThe average rate per second of closed TCP connections (Schema registry).gaugeconnection
confluent.kafka.schema.registry.jetty.connections_opened_rateThe average rate per second of opened TCP connections (Schema registry).gaugeconnection
confluent.kafka.schema.registry.json_schemas_createdschemas created jsongauge-
confluent.kafka.schema.registry.json_schemas_deletedschemas deleted jsongauge-
confluent.kafka.schema.registry.master_slave_role.master_slave_roleThe current role of this Schema Registry instance. A value of 1 indicates this instance is the primary, 0 indicates it is a secondary.gauge-
confluent.kafka.schema.registry.protobuf_schemas_createdschemas protobuf avrogauge-
confluent.kafka.schema.registry.protobuf_schemas_deletedschemas deleted protobufgauge-
confluent.kafka.schema.registry.registered_countschemas registeredgauge-
confluent.kafka.server.broker_topic_metrics.bytes_in_per_secTotal bytes in per topicgaugebyte
confluent.kafka.server.broker_topic_metrics.bytes_out_per_secTotal bytes out per topicgaugebyte
confluent.kafka.server.broker_topic_metrics.fetch_message_conversions_per_secTotal messages converted at production per topicgaugemessage
confluent.kafka.server.broker_topic_metrics.messages_in_per_secTotal messages in per topicgaugemessage
confluent.kafka.server.broker_topic_metrics.messages_out_per_secTotal messages out per topicgaugemessage
confluent.kafka.server.broker_topic_metrics.produce_message_conversions_per_secTotal messages converted at production per topicgaugemessage
confluent.kafka.server.delayed_operation_purgatory.purgatory_sizeNumber of requests waiting in the fetch purgatory. This is high if consumers use a large value for fetch.wait.max.ms.gaugerequest
confluent.kafka.server.fetcher_lag.consumer_lagLag in number of messages per follower replica. This is useful to know if the replica is slow or has stopped replicating from the leader.gaugemessage
confluent.kafka.server.produce.delay_queue_sizeNumber of producer clients currently being throttled. The value can be any number greater than or equal to 0.gauge-
confluent.kafka.server.replica_fetcher_manager.max_lagMaximum lag in messages between the follower and leader replicas. This is controlled by the replica.lag.max.messages config.gaugemessage
confluent.kafka.server.replica_manager.isr_expands_per_sec.rateRate at which the pool of in-sync replicas (ISRs) expands.gaugeunit
confluent.kafka.server.replica_manager.isr_shrinks_per_sec.rateRate at which the pool of in-sync replicas (ISRs) shrinks.gaugeunit
confluent.kafka.server.replica_manager.leader_countNumber of leaders on this broker. This should be mostly even across all brokers. If not, set auto.leader.rebalance.enable to true on all brokers in the cluster.gauge-
confluent.kafka.server.replica_manager.partition_countNumber of partitions on this broker. This should be mostly even across all brokers.gauge-
confluent.kafka.server.replica_manager.under_min_isr_partition_countNumber of partitions whose in-sync replicas count is less than minIsr.gauge-
confluent.kafka.server.replica_manager.under_replicated_partitionsNumber of under-replicated partitions (ISR < all replicas).gauge-
confluent.kafka.server.request_handler_pool.avg_idle_percentAverage fraction of time the request handler threads are idle. Values are between 0 (all resources are used) and 1 (all resources are available)gaugefraction
confluent.kafka.server.request_handler_pool.avg_idle_percent.rateNumber of nanoseconds where the request handler threads were idle during the last second. Values are between 0 (all resources are used) and 10^9 (all resources are available)gaugefraction
confluent.kafka.server.session.zoo_keeper_auth_failures_per_sec.rateAn attempt to connect to the ensemble failed because the client has not provided correct credentials.gauge/second
confluent.kafka.server.session.zoo_keeper_disconnects_per_sec.rateZooKeeper client is currently disconnected from the ensemble. The client lost its previous connection to a server and it is currently trying to reconnect. The session is not necessarily expired.gaugeunit/second
confluent.kafka.server.session.zoo_keeper_expires_per_sec.rateThe ZooKeeper session has expired. When a session expires, we can have leader changes and even a new controller.gaugeunit/second
confluent.kafka.server.session.zoo_keeper_read_only_connects_per_sec.rateThe server the client is connected to is currently LOOKING, which means that it is neither FOLLOWING nor LEADING.gaugeunit/second
confluent.kafka.server.session.zoo_keeper_request_latency_msClient request latencygaugeunit/millisecond
confluent.kafka.server.session.zoo_keeper_sasl_authentications_per_sec.rateClient has successfully authenticated.gaugeunit/second
confluent.kafka.server.session.zoo_keeper_sync_connects_per_sec.rateZooKeeper client is connected to the ensemble and ready to execute operations.gaugeunit/second
confluent.kafka.server.topic.bytes_in_per_sec.rateAggregate incoming byte rate.gaugebyte/second
confluent.kafka.server.topic.bytes_out_per_sec.rateAggregate outgoing byte rate.gaugebyte/second
confluent.kafka.server.topic.bytes_rejected_per_sec.rateAggregate rejected byte rate.gaugebyte/second
confluent.kafka.server.topic.failed_fetch_requests_per_sec.rateFetch request rate for requests that failed.gaugerequest/second
confluent.kafka.server.topic.failed_produce_requests_per_sec.rateProduce request rate for requests that failed.gaugerequest/second
confluent.kafka.server.topic.messages_in_per_sec.rateAggregate incoming message rate.gaugemessage/second
confluent.kafka.server.topic.total_fetch_requests_per_sec.rateFetch request rate.gaugerequest/second
confluent.kafka.server.topic.total_produce_requests_per_sec.rateProduce request rate.gaugerequest/second
confluent.kafka.streams.processor_node.forward_rateThe average rate of records being forwarded downstream, from source nodes only, per second. This metric can be used to understand how fast the library is consuming from source topics.gaugerecord/second
confluent.kafka.streams.processor_node.forward_totalThe total number of records being forwarded downstream, from source nodes only.gaugerecord
confluent.kafka.streams.processor_node.process_latency_avgThe average execution time in ns, for the respective operation.gaugenanosecond
confluent.kafka.streams.processor_node.process_rateThe average number of respective operations per second.gaugeoperation/second
confluent.kafka.streams.processor_node.process_totalThe total number of respective operations.gaugeoperation
confluent.kafka.streams.processor_node.suppression_emit_rateThe rate at which records that have been emitted downstream from suppression operation nodes. Compare with the process-rate metric to determine how many updates are being suppressed.gaugerecord/second
confluent.kafka.streams.processor_node.suppression_emit_totalThe total number of records that have been emitted downstream from suppression operation nodes. Compare with the process-total metric to determine how many updates are being suppressed.gaugerecord
confluent.kafka.streams.stream.commit_latency_avgThe average value of commit-latency.gaugenanosecond
confluent.kafka.streams.stream.commit_latency_maxThe maximum value of commit-latency.gaugenanosecond
confluent.kafka.streams.stream.commit_rateThe average per-second number of commit callsgaugecommit/second
confluent.kafka.streams.stream.commit_totalThe total number of commit callsgaugecommit
confluent.kafka.streams.stream.poll_latency_avgThe average value of poll-latency.gaugenanosecond
confluent.kafka.streams.stream.poll_latency_maxThe maximum value of poll-latency.gaugenanosecond
confluent.kafka.streams.stream.poll_rateThe average per-second number of poll callsgaugeunit/second
confluent.kafka.streams.stream.poll_totalThe total number of poll callsgaugeunit
confluent.kafka.streams.stream.process_latency_avgThe average value of process-latency.gaugenanosecond
confluent.kafka.streams.stream.process_latency_maxThe maximum value of process-latency.gaugenanosecond
confluent.kafka.streams.stream.process_rateThe average per-second number of process callsgaugeunit/second
confluent.kafka.streams.stream.process_totalThe total number of process callsgaugeunit
confluent.kafka.streams.stream.punctuate_latency_avgThe average value of punctuate-latency.gaugenanosecond
confluent.kafka.streams.stream.punctuate_latency_maxThe maximum value of punctuate-latency.gaugenanosecond
confluent.kafka.streams.stream.punctuate_rateThe average per-second number of punctuate callsgaugeunit/second
confluent.kafka.streams.stream.punctuate_totalThe total number of punctuate callsgaugeunit
confluent.kafka.streams.stream.skipped_records_rateThe average per-second number of skipped recordsgaugerecord/second
confluent.kafka.streams.stream.skipped_records_totalThe total number of skipped recordsgaugerecord
confluent.kafka.streams.stream.task_closed_rateThe average per-second number of closed tasksgaugetask/second
confluent.kafka.streams.stream.task_closed_totalThe total number of closed tasksgaugetask
confluent.kafka.streams.stream.task_created_rateThe average per-second number of newly created tasksgaugetask/second
confluent.kafka.streams.stream.task_created_totalThe total number of newly created tasksgaugetask
confluent.kafka.streams.task.commit_latency_avgThe average value of task commit-latency.gaugenanosecond
confluent.kafka.streams.task.commit_rateThe average per-second number of commit calls over all tasksgaugeunit/second
confluent.kafka.streams.task.record_lateness_avgThe average value of record-lateness.gaugemillisecond
confluent.ksql.consumer_metrics.consumer_messages_per_secconsumer_messages_per_secgauge-
confluent.ksql.consumer_metrics.consumer_total_bytesconsumer_total_bytesgauge-
confluent.ksql.consumer_metrics.consumer_total_messagesconsumer_total_messagesgauge-
confluent.ksql.ksql_rocksdb_aggregates.block_cache_pinned_usage_maxblock_cache_pinned_usage_maxgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.block_cache_pinned_usage_totalblock_cache_pinned_usage_totalgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.block_cache_usage_maxblock cache usagegaugebyte
confluent.ksql.ksql_rocksdb_aggregates.block_cache_usage_totalblock_cache_usage_totalgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.compaction_pending_totalcompaction_pending_totalgauge-
confluent.ksql.ksql_rocksdb_aggregates.cur_size_active_mem_table_totalcur_size_active_mem_table_totalgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.cur_size_all_mem_tables_totalsize all mem tablesgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.estimate_num_keys_totalestimate_num_keys_totalgauge-
confluent.ksql.ksql_rocksdb_aggregates.estimate_pending_compaction_bytes_totalestimate_pending_compaction_bytes_totalgauge-
confluent.ksql.ksql_rocksdb_aggregates.estimate_table_readers_mem_totalestimate_table_readers_mem_totalgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.live_sst_files_size_totallive_sst_files_size_totalgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.mem_table_flush_pending_totalmem_table_flush_pending_totalgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.num_deletes_active_mem_table_totalnum_deletes_active_mem_table_totalgauge-
confluent.ksql.ksql_rocksdb_aggregates.num_deletes_imm_mem_tables_totaldelete all mem tablesgauge-
confluent.ksql.ksql_rocksdb_aggregates.num_entries_active_mem_table_totalentries all mem tablesgauge-
confluent.ksql.ksql_rocksdb_aggregates.num_entries_imm_mem_tables_totalnum_entries_imm_mem_tables_totalgaugebyte
confluent.ksql.ksql_rocksdb_aggregates.num_immutable_mem_table_totalimmutable mem table totalgauge-
confluent.ksql.ksql_rocksdb_aggregates.num_running_compactions_totalnum_running_compactionsgauge-
confluent.ksql.ksql_rocksdb_aggregates.num_running_flushes_totalrunning flushes totalgauge-
confluent.ksql.ksql_rocksdb_aggregates.total_sst_files_size_totaltotal_sst_files_size_totalgaugebyte
confluent.ksql.producer_metrics.messages_per_secmessages_per_secgauge-
confluent.ksql.producer_metrics.total_messagestotal messagesgauge-
confluent.ksql.pull_query_metrics.pull_query_requests_error_ratepull_query_requests_error_rategauge-
confluent.ksql.pull_query_metrics.pull_query_requests_error_totalpull_query_requests_error_totalgauge-
confluent.ksql.pull_query_metrics.pull_query_requests_latency_distribution_50pull_query_requests_latency_distribution_50gauge-
confluent.ksql.pull_query_metrics.pull_query_requests_latency_distribution_75pull_query_requests_latency_distribution_75gauge-
confluent.ksql.pull_query_metrics.pull_query_requests_latency_distribution_90pull_query_requests_latency_distribution_90gauge-
confluent.ksql.pull_query_metrics.pull_query_requests_latency_distribution_99pull_query_requests_latency_distribution_99gauge-
confluent.ksql.pull_query_metrics.pull_query_requests_latency_latency_avgpull_query_requests_latency_latency_avggauge-
confluent.ksql.pull_query_metrics.pull_query_requests_latency_latency_maxpull_query_requests_latency_latency_maxgauge-
confluent.ksql.pull_query_metrics.pull_query_requests_latency_latency_minpull_query_requests_latency_latency_mingauge-
confluent.ksql.pull_query_metrics.pull_query_requests_localpull_query_requests_localgauge-
confluent.ksql.pull_query_metrics.pull_query_requests_local_ratepull_query_requests_local_rategauge-
confluent.ksql.pull_query_metrics.pull_query_requests_ratepull_query_requests_rategauge-
confluent.ksql.pull_query_metrics.pull_query_requests_remotepull_query_requests_remotegauge-
confluent.ksql.pull_query_metrics.pull_query_requests_remote_ratepull_query_requests_remote_rategauge-
confluent.ksql.pull_query_metrics.pull_query_requests_totalpull_query_requests_totalgauge-
confluent.ksql.query_stats.bytes_consumed_totalNumber of bytes consumed across all queries.gaugebyte
confluent.ksql.query_stats.created_queriesCREATED_queriesgaugemessage
confluent.ksql.query_stats.error_queriesgaugemessage
confluent.ksql.query_stats.error_rateNumber of messages that have been consumed but not processed across all queries.gaugemessage
confluent.ksql.query_stats.messages_consumed_avgAverage number of messages consumed by a query per second.gaugemessage/second
confluent.ksql.query_stats.messages_consumed_maxNumber of messages consumed per second for the query with the most messages consumed per second.gaugemessage/second
confluent.ksql.query_stats.messages_consumed_minNumber of messages consumed per second for the query with the fewest messages consumed per second.gaugemessage/second
confluent.ksql.query_stats.messages_consumed_per_secNumber of messages consumed per second across all queries.gaugemessage/second
confluent.ksql.query_stats.messages_consumed_totalNumber of messages consumed across all queries.gaugemessage
confluent.ksql.query_stats.messages_produced_per_secNumber of messages produced per second across all queries.gaugemessage/second
confluent.ksql.query_stats.not_running_queriesNOT_RUNNING_queriesgaugemessage
confluent.ksql.query_stats.num_active_queriesNumber of queries that are actively processing messages.gaugemessage
confluent.ksql.query_stats.num_idle_queriesNumber of queries with no messages available to process.gaugemessage
confluent.ksql.query_stats.num_persistent_queriesNumber of persistent queries that are currently executing.gaugequery
confluent.ksql.query_stats.pending_shutdown_queriesPENDING_SHUTDOWN_queriesgaugemessage
confluent.ksql.query_stats.rebalancing_queriesREBALANCING_queriesgaugemessage
confluent.ksql.query_stats.running_queriesRUNNING_queriesgaugemessage
confluent.replicator.task.topic_partition_latencyThe average time between message production to the source cluster and message production to the destination cluster.gauge-
confluent.replicator.task.topic_partition_message_lagThe number of messages that were produced to the origin cluster, but have not yet arrived to the destination cluster.gaugemessage
confluent.replicator.task.topic_partition_throughputThe number of messages replicated per second from the source to destination cluster.gaugemessage/second

公式ドキュメント

Confluent Platform インテグレーションの公式ドキュメント

メトリクスの名前と説明は Datadog の公式インテグレーションの定義 (Copyright Datadog, Inc.・BSD-3-Clause) を英文のまま載せています。利用条件の全文は サイトについてにあります。