--- title: Confluent Cloud description: Collect various Kafka metrics and related cost data from Confluent Cloud. breadcrumbs: Docs > Integrations > Confluent Cloud --- # Confluent Cloud Integration version1.0.0Confluent Cloud Dashboard Overview ## Overview{% #overview %} {% callout %} # Important note for users on the following Datadog sites: app.ddog-gov.com **The Confluent Cloud integration is not supported for the Datadog site**. {% /callout %} Confluent Cloud is a fully managed, cloud-hosted streaming data service. Connect Datadog with Confluent Cloud to visualize and alert on key metrics for your Confluent Cloud resources. Datadog's out-of-the-box Confluent Cloud dashboard shows you key cluster metrics for monitoring the health and performance of your environment, including information such as the rate of change in active connections and your ratio of average consumed to produced records. You can use recommended monitors to notify and alert your team when topic lag is getting too high, or use these metrics to create your own. ## Setup{% #setup %} ### Installation{% #installation %} Install the integration with the [Datadog Confluent Cloud integration tile](https://app.datadoghq.com/integrations/confluent-cloud). ### Configuration{% #configuration %} 1. In Confluent Cloud, click **+ Add API Key** to enter your Confluent Cloud API Key and API Secret. - Create a **Cloud Resource Management** API key and secret. - Click **Save**. Datadog searches for accounts associated with those credentials. - In the Datadog integration configuration, add the API key and secret to the **API Key and API Secret** fields. 1. Add your Confluent Cloud Cluster ID or Connector ID. Datadog crawls the Confluent Cloud metrics and loads metrics within minutes. 1. To collect your tags defined in Confluent Cloud (optional): - Create a **Schema Registry** API key and secret. Read more about [Schema Management on Confluent Cloud](https://docs.confluent.io/cloud/current/get-started/schema-registry.html#quick-start-for-schema-management-on-ccloud). - Click **Save**. Datadog collects tags defined in Confluent Cloud. - In the Datadog integration configuration, add the API key and secret to the **Schema Registry API Key and Secret** fields. 1. If you use Cloud Cost Management and enable collecting cost data: - Ensure that the API key has the [BillingAdmin role](https://docs.confluent.io/cloud/current/access-management/access-control/rbac/predefined-rbac-roles.html#billingadmin-role) enabled. - It will be visible in [Cloud Cost Management](https://app.datadoghq.com/cost) within 24 hours. ([collected data](https://docs.datadoghq.com/cloud_cost_management/setup/saas_costs.md?tab=confluentcloud#data-collected)) For more information about configuration resources, such as Clusters and Connectors, refer to the [Confluent Cloud Integration documentation](https://docs.datadoghq.com/integrations/confluent_cloud.md). #### API Key and secret{% #api-key-and-secret %} To create your Confluent Cloud API Key and Secret, see [Add the MetricsViewer role to a new service account in the UI](https://docs.confluent.io/cloud/current/monitoring/metrics-api.html#add-the-metricsviewer-role-to-a-new-service-account-in-the-ui). #### Cluster ID{% #cluster-id %} To find your Confluent Cloud Cluster ID: 1. In Confluent Cloud, navigate to **Environment Overview** and select the cluster you want to monitor. 1. In the left-hand navigation, click **Cluster overview** > **Cluster settings**. 1. Under **Identification**, copy the Cluster ID beginning with `lkc`. #### Connector ID{% #connector-id %} To find your Confluent Cloud Connector ID: 1. In Confluent Cloud, navigate to **Environment Overview** and select the cluster you want to monitor. 1. In the left-hand navigation, click **Data integration** > **Connectors**. 1. Under **Connectors**, copy the Connector ID beginning with `lcc`. ## Dashboards{% #dashboards %} After configuring the integration, see the out-of-the-box Confluent Cloud dashboard for an overview of Kafka cluster and connector metrics. By default, all metrics collected across Confluent Cloud are displayed. ## Data Collected{% #data-collected %} ### Metrics{% #metrics %} | | | | | **confluent\_cloud.kafka.received\_bytes**(count) | The delta count of bytes received from the network. Each sample is the number of bytes received since the previous data sample. The count is sampled every 60 seconds.*Shown as byte* | | **confluent\_cloud.kafka.sent\_bytes**(count) | The delta count of bytes sent over the network. Each sample is the number of bytes sent since the previous data point. The count is sampled every 60 seconds.*Shown as byte* | | **confluent\_cloud.kafka.received\_records**(count) | The delta count of records received. Each sample is the number of records received since the previous data sample. The count is sampled every 60 seconds.*Shown as record* | | **confluent\_cloud.kafka.sent\_records**(count) | The delta count of records sent. Each sample is the number of records sent since the previous data point. The count is sampled every 60 seconds.*Shown as record* | | **confluent\_cloud.kafka.retained\_bytes**(gauge) | The current count of bytes retained by the cluster. The count is sampled every 60 seconds.*Shown as byte* | | **confluent\_cloud.kafka.active\_connection\_count**(gauge) | The count of active authenticated connections.*Shown as connection* | | **confluent\_cloud.kafka.connection\_info**(gauge) | Client connection metadata.*Shown as connection* | | **confluent\_cloud.kafka.request\_count**(count) | The delta count of requests received over the network. Each sample is the number of requests received since the previous data point. The count is sampled every 60 seconds.*Shown as request* | | **confluent\_cloud.kafka.partition\_count**(gauge) | The number of partitions. | | **confluent\_cloud.kafka.successful\_authentication\_count**(count) | The delta count of successful authentications. Each sample is the number of successful authentications since the previous data point. The count is sampled every 60 seconds.*Shown as attempt* | | **confluent\_cloud.kafka.cluster\_link\_destination\_response\_bytes**(count) | The delta count of cluster linking response bytes from all request types. Each sample is the number of bytes sent since the previous data point. The count is sampled every 60 seconds.*Shown as byte* | | **confluent\_cloud.kafka.cluster\_link\_source\_response\_bytes**(count) | The delta count of cluster linking source response bytes from all request types. Each sample is the number of bytes sent since the previous data point. The count is sampled every 60 seconds.*Shown as byte* | | **confluent\_cloud.kafka.cluster\_active\_link\_count**(gauge) | The current count of active cluster links. The count is sampled every 60 seconds. The implicit time aggregation for this metric is MAX. | | **confluent\_cloud.kafka.cluster\_load\_percent**(gauge) | A measure of the utilization of the cluster. The value is between 0.0 and 1.0.*Shown as percent* | | **confluent\_cloud.kafka.cluster\_load\_percent\_max**(gauge) | A measure of the maximum broker utilization across the cluster. The value is between 0.0 and 1.0.*Shown as percent* | | **confluent\_cloud.kafka.cluster\_load\_percent\_avg**(gauge) | A measure of the average utilization across the cluster. The value is between 0.0 and 1.0.*Shown as percent* | | **confluent\_cloud.kafka.consumer\_lag\_offsets**(gauge) | The lag between a group member's committed offset and the partition's high watermark. Tagged with `consumer_group_id` and topic. | | **confluent\_cloud.kafka.cluster\_link\_count**(gauge) | The current count of cluster links. The count is sampled every 60 seconds. The implicit time aggregation for this metric is MAX. | | **confluent\_cloud.kafka.cluster\_link\_task\_count**(gauge) | The current count of cluster links tasks. The count is sampled every 60 seconds. The implicit time aggregation for this metric is MAX. | | **confluent\_cloud.kafka.cluster\_link\_mirror\_transition\_in\_error**(gauge) | The cluster linking mirror topic state transition error count for a link. The count is sampled every 60 seconds. | | **confluent\_cloud.kafka.cluster\_link\_mirror\_topic\_bytes**(count) | The delta count of cluster linking mirror topic bytes. The count is sampled every 60 seconds. | | **confluent\_cloud.kafka.cluster\_link\_mirror\_topic\_count**(gauge) | The cluster linking mirror topic count for a link. The count is sampled every 60 seconds. | | **confluent\_cloud.kafka.cluster\_link\_mirror\_topic\_offset\_lag**(gauge) | TThe cluster linking mirror topic offset lag maximum across all partitions. The lag is sampled every 60 seconds. | | **confluent\_cloud.kafka.request\_bytes**(gauge) | The delta count of total request bytes from the specified request types sent over the network. Each sample is the number of bytes sent since the previous data point. The count is sampled every 60 seconds. | | **confluent\_cloud.kafka.response\_bytes**(gauge) | The delta count of total response bytes from the specified response types sent over the network. Each sample is the number of bytes sent since the previous data point. The count is sampled every 60 seconds. | | **confluent\_cloud.kafka.rest\_produce\_request\_bytes**(count) | The delta count of total request bytes from Kafka REST produce calls sent over the network requested by Kafka REST. | | **confluent\_cloud.kafka.dedicated\_cku\_count**(count) | CKU count of a dedicated cluster | | **confluent\_cloud.kafka.hot\_partition\_ingress**(gauge) | An indicator of the presence of a hot partition caused by ingress throughput. | | **confluent\_cloud.kafka.hot\_partition\_egress**(gauge) | An indicator of the presence of a hot partition caused by egress throughput. | | **confluent\_cloud.kafka.producer\_latency\_avg\_milliseconds**(gauge) | The average latency of client producer request.*Shown as millisecond* | | **confluent\_cloud.connect.connector\_status**(count) | This metric monitors the status of a connector within the system. Its value is always set to 1 which signifies connector presence. The current operational state of the connector is identified through the status tag.*Shown as record* | | **confluent\_cloud.connect.dynamodb\_cdc\_source\_connector\_lag\_milliseconds**(gauge) | Represents the number of milliseconds between the last change event's timestamp and the connector processing it. Applies only to the DynamoDb CDC source connector.*Shown as record* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_lag\_milliseconds**(gauge) | Represents the number of milliseconds between the last change event's timestamp and the connector processing it. Applies only to the MySQL CDC source V2 connector.*Shown as record* | | **confluent\_cloud.connect.oracle\_cdc\_source\_connector\_lag\_milliseconds**(gauge) | Represents the number of milliseconds between the last change event's timestamp and the connector processing it. Applies only to the Oracle CDC source connector.*Shown as record* | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_lag\_milliseconds**(gauge) | Represents the number of milliseconds between the last change event's timestamp and the connector processing it. Applies only to the Postgres CDC source V2 connector.*Shown as record* | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_lag\_milliseconds**(gauge) | Represents the number of milliseconds between the last change event's timestamp and the connector processing it. Applies only to the SQL Server CDC source V2 connector.*Shown as record* | | **confluent\_cloud.connect.connector\_task\_batch\_size\_avg**(gauge) | Monitors the average batch size (measured by record count) per minute. For a source connector it indicates the average batch size sent to Kafka.*Shown as percent* | | **confluent\_cloud.connect.connector\_task\_batch\_size\_max**(gauge) | Monitors the maximum batch size (measured by record count) per minute. For a source connector it indicates the max batch size sent to Kafka.*Shown as percent* | | **confluent\_cloud.connect.connector\_task\_status**(gauge) | Monitors the status of a connector's task within the system. Its value is always set to 1 signifying the connector task's presence. | | **confluent\_cloud.connect.dead\_letter\_queue\_records**(count) | The delta count of dead letter queue records written to Kafka for the sink connector. The count is sampled every 60 seconds.*Shown as record* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_schema\_history\_status**(gauge) | It represents the status of the schema history of the connector. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_snapshot\_completed**(gauge) | It represents whether the Snapshot is completed. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_snapshot\_running**(gauge) | It represents whether the Snapshot is running. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_snapshot\_completed**(gauge) | It represents whether the Snapshot is completed. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_snapshot\_running**(gauge) | It represents whether the Snapshot is running. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.connect.received\_bytes**(count) | The delta count of total bytes received by the sink connector. Each sample is the number of bytes received since the previous data point. The count is sampled every 60 seconds.*Shown as byte* | | **confluent\_cloud.connect.received\_records**(count) | The delta count of total number of records received by the sink connector. Each sample is the number of records received since the previous data point. The count is sampled every 60 seconds.*Shown as record* | | **confluent\_cloud.connect.records\_lag\_max**(gauge) | The max number of records the sink connector is behind among all partitions. The count is sampled every 60 seconds.*Shown as record* | | **confluent\_cloud.connect.sent\_bytes**(count) | The delta count of total bytes sent from the transformations and written to Kafka for the source connector. Each sample is the number of bytes sent since the previous data point. The count is sampled every 60 seconds.*Shown as byte* | | **confluent\_cloud.connect.sent\_records**(count) | The delta count of total number of records sent from the transformations and written to Kafka for the source connector. Each sample is the number of records sent since the previous data point. The count is sampled every 60 seconds.*Shown as record* | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_schema\_history\_status**(gauge) | It represents the status of the schema history of the connector. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_snapshot\_completed**(gauge) | It represents whether the Snapshot is completed. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_snapshot\_running**(gauge) | It represents whether the Snapshot is running. The values will incorporate any differences between the clocks on the machines where the database server and the connector are running. | | **confluent\_cloud.ksql.streaming\_unit\_count**(gauge) | The count of Confluent Streaming Units (CSUs) for this KSQL instance. The count is sampled every 60 seconds. The implicit time aggregation for this metric is MAX.*Shown as unit* | | **confluent\_cloud.ksql.query\_saturation**(gauge) | The maximum saturation for a given ksqlDB query across all nodes. Returns a value between 0 and 1. A value close to 1 indicates that ksqlDB query processing is bottlenecked on available resources. | | **confluent\_cloud.ksql.task\_stored\_bytes**(gauge) | The size of a given task's state stores in bytes.*Shown as byte* | | **confluent\_cloud.ksql.storage\_utilization**(gauge) | The total storage utilization for a given ksqlDB application. | | **confluent\_cloud.schema\_registry.schema\_count**(gauge) | The number of registered schemas. | | **confluent\_cloud.schema\_registry.request\_count**(count) | The delta count of requests received by the schema registry server. Each sample is the number of requests received since the previous data point. The count sampled every 60 seconds. | | **confluent\_cloud.kafka.deprecated\_request\_count**(count) | The delta count of deprecated requests received over the network. Each sample is the number of requests received since the previous data point. The count is sampled every 60 seconds.*Shown as request* | | **confluent\_cloud.schema\_registry.schema\_operations\_count**(count) | The delta count of schema related operations. Each sample is the number of requests received since the previous data point. The count sampled every 60 seconds. | | **confluent\_cloud.flink.num\_records\_in**(count) | Total number of records all Flink SQL statements leveraging a Flink compute pool have received. | | **confluent\_cloud.flink.num\_records\_out**(count) | Total number of records all Flink SQL statements leveraging a Flink compute pool have emitted. | | **confluent\_cloud.flink.pending\_records**(gauge) | Total backlog of all Flink SQL statements leveraging a Flink compute pool. | | **confluent\_cloud.flink.compute\_pool\_utilization.current\_cfus**(gauge) | The absolute number of CFUs at a given moment. | | **confluent\_cloud.flink.compute\_pool\_utilization.cfu\_minutes\_consumed**(count) | The number of how many CFUs consumed since the last measurement. | | **confluent\_cloud.flink.compute\_pool\_utilization.cfu\_limit**(gauge) | The possible max number of CFUs for the pool. | | **confluent\_cloud.flink.current\_input\_watermark\_ms**(gauge) | The last watermark this statement has received (in milliseconds) for the given table. | | **confluent\_cloud.flink.current\_output\_watermark\_ms**(gauge) | The last watermark this statement has produced (in milliseconds) to the given table. | | **confluent\_cloud.flink.current\_input\_watermark\_milliseconds**(gauge) | The last input watermark (in milliseconds) this statement has received for the given table.*Shown as millisecond* | | **confluent\_cloud.flink.current\_output\_watermark\_milliseconds**(gauge) | The last output watermark (in milliseconds) this statement has produced for the given table.*Shown as millisecond* | | **confluent\_cloud.flink.external\_table\_bytes\_in**(count) | Bytes read from an external table by Flink SQL statements in the compute pool.*Shown as byte* | | **confluent\_cloud.flink.external\_table\_bytes\_out**(count) | Bytes written to an external table by Flink SQL statements in the compute pool.*Shown as byte* | | **confluent\_cloud.flink.materialized\_table\_utilization.cfu\_minutes\_consumed**(count) | CFU minutes consumed for the materialized table since the last measurement.*Shown as minute* | | **confluent\_cloud.flink.materialized\_table\_utilization.current\_cfus**(gauge) | Current CFU allocation for the materialized table. | | **confluent\_cloud.flink.max\_input\_lateness\_milliseconds**(gauge) | Maximum lateness of incoming records observed for the given table.*Shown as millisecond* | | **confluent\_cloud.flink.num\_late\_records\_in**(count) | Count of late records received for the given table.*Shown as record* | | **confluent\_cloud.flink.num\_records\_in\_from\_files**(count) | Records read from files for the given table.*Shown as record* | | **confluent\_cloud.flink.num\_records\_in\_from\_topics**(count) | Records read from Kafka topics for the given table.*Shown as record* | | **confluent\_cloud.flink.operator.current\_parallelism**(gauge) | Current parallelism of the Flink operator. | | **confluent\_cloud.flink.operator.max\_input\_lateness\_milliseconds**(gauge) | Maximum input lateness in milliseconds at the operator.*Shown as millisecond* | | **confluent\_cloud.flink.operator.max\_parallelism**(gauge) | Maximum parallelism configured for the Flink operator. | | **confluent\_cloud.flink.operator.num\_bytes\_in**(count) | Bytes received by the operator per sampling interval.*Shown as byte* | | **confluent\_cloud.flink.operator.num\_bytes\_out**(count) | Bytes sent by the operator per sampling interval.*Shown as byte* | | **confluent\_cloud.flink.operator.num\_records\_in**(count) | Records received by the operator per sampling interval.*Shown as record* | | **confluent\_cloud.flink.operator.num\_records\_out**(count) | Records emitted by the operator per sampling interval.*Shown as record* | | **confluent\_cloud.flink.operator.state\_size\_bytes**(gauge) | Size of managed operator state in bytes.*Shown as byte* | | **confluent\_cloud.flink.operator.num\_late\_records\_in**(count) | Late records observed at the operator.*Shown as record* | | **confluent\_cloud.flink.split.current\_watermark\_ms**(gauge) | Current watermark for the split in milliseconds.*Shown as millisecond* | | **confluent\_cloud.flink.split.watermark\_active\_time\_ms\_per\_second**(gauge) | Per second time the split watermark was active (milliseconds).*Shown as millisecond* | | **confluent\_cloud.flink.split.watermark\_idle\_time\_ms\_per\_second**(gauge) | Per second time the split watermark was idle (milliseconds).*Shown as millisecond* | | **confluent\_cloud.flink.split.watermark\_paused\_time\_ms\_per\_second**(gauge) | Per second time the split watermark was paused (milliseconds).*Shown as millisecond* | | **confluent\_cloud.flink.statement\_status**(gauge) | Status of the Flink SQL statement (for example running failed or stopped). | | **confluent\_cloud.flink.statement\_utilization.cfu\_minutes\_consumed**(count) | CFU minutes consumed for the Flink SQL statement since the last measurement.*Shown as minute* | | **confluent\_cloud.flink.statement\_utilization.current\_cfus**(gauge) | Current CFU allocation for the Flink SQL statement. | | **confluent\_cloud.flink.task.backpressure\_time\_ms\_per\_second**(gauge) | Per second time the task spent backpressured (milliseconds).*Shown as millisecond* | | **confluent\_cloud.flink.task.busy\_time\_ms\_per\_second**(gauge) | Per second time the task was busy (milliseconds).*Shown as millisecond* | | **confluent\_cloud.flink.task.idle\_time\_ms\_per\_second**(gauge) | Per second time the task was idle (milliseconds).*Shown as millisecond* | | **confluent\_cloud.flink.task.max\_input\_lateness\_milliseconds**(gauge) | Maximum input lateness in milliseconds at the task.*Shown as millisecond* | | **confluent\_cloud.flink.task.num\_bytes\_in**(count) | Bytes received by the task per sampling interval.*Shown as byte* | | **confluent\_cloud.flink.task.num\_bytes\_out**(count) | Bytes sent by the task per sampling interval.*Shown as byte* | | **confluent\_cloud.flink.task.num\_late\_records\_in**(count) | Late records observed at the task.*Shown as record* | | **confluent\_cloud.flink.task.num\_records\_in**(count) | Records received by the task per sampling interval.*Shown as record* | | **confluent\_cloud.flink.task.num\_records\_out**(count) | Records emitted by the task per sampling interval.*Shown as record* | | **confluent\_cloud.custom.kafka.consumer\_lag\_offsets**(gauge) | The lag between a group member's committed offset and the partition's high watermark. Tagged with `consumer_group_id`, topic, partition, `consumer_group_id` and `client_id`. | | **confluent\_cloud.tableflow.snapshots\_generated**(count) | Delta count of snapshots generated for a Tableflow table. | | **confluent\_cloud.tableflow.rows\_added**(count) | Delta count of rows added to a Tableflow table.*Shown as record* | | **confluent\_cloud.tableflow.rows\_read**(count) | Delta count of rows read from a Tableflow table.*Shown as record* | | **confluent\_cloud.tableflow.bytes\_added**(count) | Delta count of bytes added to a Tableflow table.*Shown as byte* | | **confluent\_cloud.tableflow.bytes\_read**(count) | Delta count of bytes read from a Tableflow table.*Shown as byte* | | **confluent\_cloud.tableflow.kafka\_topic\_offset**(gauge) | Kafka topic offset for a Tableflow table. | | **confluent\_cloud.tableflow.table\_offset**(gauge) | Table offset for a Tableflow table. | | **confluent\_cloud.tableflow.bytes\_processed**(count) | Delta count of bytes processed by Tableflow.*Shown as byte* | | **confluent\_cloud.tableflow.num\_topics**(gauge) | Number of topics with Tableflow enabled. | | **confluent\_cloud.tableflow.storage**(gauge) | Storage utilization for Tableflow tables.*Shown as byte* | | **confluent\_cloud.tableflow.bytes\_compacted**(count) | Delta count of bytes compacted by Tableflow.*Shown as byte* | | **confluent\_cloud.tableflow.files\_compacted**(count) | Delta count of files compacted by Tableflow. | | **confluent\_cloud.tableflow.rows\_skipped**(count) | Delta count of rows skipped during Tableflow processing.*Shown as record* | | **confluent\_cloud.tableflow.compactions\_pending**(count) | Number of pending Tableflow compactions. | | **confluent\_cloud.tableflow.compaction\_duration**(gauge) | Duration of Tableflow compaction operations.*Shown as millisecond* | | **confluent\_cloud.tableflow.delta\_bytes\_added**(count) | Delta count of bytes added to Tableflow delta.*Shown as byte* | | **confluent\_cloud.tableflow.delta\_rows\_added**(count) | Delta count of rows added to Tableflow delta.*Shown as record* | | **confluent\_cloud.tableflow.delta\_versions\_generated**(count) | Delta count of delta versions generated by Tableflow. | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_snapshot\_milliseconds\_since\_last\_event**(gauge) | Milliseconds since the last snapshot event for the PostgreSQL CDC source connector.*Shown as millisecond* | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_snapshot\_aborted**(gauge) | Whether the PostgreSQL CDC source connector snapshot was aborted. | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_snapshot\_paused\_duration\_in\_seconds**(gauge) | Duration in seconds that the PostgreSQL CDC source connector snapshot was paused.*Shown as second* | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_snapshot\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen during the PostgreSQL CDC source connector snapshot.*Shown as event* | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_streaming\_number\_of\_committed\_transactions**(gauge) | Number of committed transactions for the PostgreSQL CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.postgres\_cdc\_source\_connector\_streaming\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen for the PostgreSQL CDC source connector.*Shown as event* | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_snapshot\_milliseconds\_since\_last\_event**(gauge) | Milliseconds since the last snapshot event for the SQL Server CDC source connector.*Shown as millisecond* | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_snapshot\_aborted**(gauge) | Whether the SQL Server CDC source connector snapshot was aborted. | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_snapshot\_paused\_duration\_in\_seconds**(gauge) | Duration in seconds that the SQL Server CDC source connector snapshot was paused.*Shown as second* | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_snapshot\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen during the SQL Server CDC source connector snapshot.*Shown as event* | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_streaming\_number\_of\_committed\_transactions**(gauge) | Number of committed transactions for the SQL Server CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.sql\_server\_cdc\_source\_connector\_streaming\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen for the SQL Server CDC source connector.*Shown as event* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_snapshot\_milliseconds\_since\_last\_event**(gauge) | Milliseconds since the last snapshot event for the MySQL CDC source connector.*Shown as millisecond* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_snapshot\_aborted**(gauge) | Whether the MySQL CDC source connector snapshot was aborted. | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_snapshot\_paused\_duration\_in\_seconds**(gauge) | Duration in seconds that the MySQL CDC source connector snapshot was paused.*Shown as second* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_snapshot\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen during the MySQL CDC source connector snapshot.*Shown as event* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_streaming\_number\_of\_committed\_transactions**(gauge) | Number of committed transactions for the MySQL CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_streaming\_number\_of\_disconnects**(gauge) | Number of disconnects for the MySQL CDC source connector. | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_streaming\_number\_of\_large\_transactions**(gauge) | Number of large transactions for the MySQL CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_streaming\_number\_of\_rolled\_back\_transactions**(gauge) | Number of rolled back transactions for the MySQL CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_streaming\_number\_of\_skipped\_events**(gauge) | Number of skipped events for the MySQL CDC source connector.*Shown as event* | | **confluent\_cloud.connect.mysql\_cdc\_source\_connector\_streaming\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen for the MySQL CDC source connector.*Shown as event* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_snapshot\_milliseconds\_since\_last\_event**(gauge) | Milliseconds since the last snapshot event for the MariaDB CDC source connector.*Shown as millisecond* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_snapshot\_aborted**(gauge) | Whether the MariaDB CDC source connector snapshot was aborted. | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_snapshot\_paused\_duration\_in\_seconds**(gauge) | Duration in seconds that the MariaDB CDC source connector snapshot was paused.*Shown as second* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_snapshot\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen during the MariaDB CDC source connector snapshot.*Shown as event* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_streaming\_number\_of\_committed\_transactions**(gauge) | Number of committed transactions for the MariaDB CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_streaming\_number\_of\_disconnects**(gauge) | Number of disconnects for the MariaDB CDC source connector. | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_streaming\_number\_of\_large\_transactions**(gauge) | Number of large transactions for the MariaDB CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_streaming\_number\_of\_rolled\_back\_transactions**(gauge) | Number of rolled back transactions for the MariaDB CDC source connector.*Shown as transaction* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_streaming\_number\_of\_skipped\_events**(gauge) | Number of skipped events for the MariaDB CDC source connector.*Shown as event* | | **confluent\_cloud.connect.mariadb\_cdc\_source\_connector\_streaming\_total\_number\_of\_events\_seen**(gauge) | Total number of events seen for the MariaDB CDC source connector.*Shown as event* | ### Events{% #events %} The Confluent Cloud integration does not include any events. ### Service Checks{% #service-checks %} The Confluent Cloud integration does not include any service checks. ## Troubleshooting{% #troubleshooting %} Need help? Contact [Datadog support](https://docs.datadoghq.com/help/). ## Further Reading{% #further-reading %} - [Monitor Confluent Cloud with Datadog](https://www.datadoghq.com/blog/confluent-cloud-monitoring-datadog/) - [Autodiscover Confluent Cloud connectors and easily monitor performance in Data Streams Monitoring](https://www.datadoghq.com/blog/confluent-connector-dsm-autodiscovery/)