---
title: Amazon MSK Connect
description: >-
  Amazon MSK Connect is a feature of Amazon MSK that makes it easy to stream
  data to and from your Apache Kafka clusters.
breadcrumbs: Docs > Integrations > Amazon MSK Connect
---

> For the complete documentation index, see [llms.txt](https://docs.datadoghq.com/llms.txt).

# Amazon MSK Connect
Integration version1.0.0
{% callout %}
# Important note for users on the following Datadog sites: us2.ddog-gov.com

{% alert level="info" %}
To find out if this integration is available in your organization, see your [Datadog Integrations](https://app.datadoghq.com/integrations) page or ask your organization administrator.

To initiate an exception request to enable this integration for your organization, email [support@ddog-gov.com](mailto:support@ddog-gov.com).
{% /alert %}

{% /callout %}

## Overview{% #overview %}

Amazon MSK Connect is a feature of Amazon MSK that makes it easy to stream data to and from your Apache Kafka clusters.

Enable this integration to see all your Amazon MSK Connect metrics in Datadog.

## Setup{% #setup %}

### Installation{% #installation %}

If you haven't already, set up the [Amazon Web Services integration](https://docs.datadoghq.com/integrations/amazon_web_services.md) first.

### Metric collection{% #metric-collection %}

1. In the [AWS integration tile](https://app.datadoghq.com/integrations/amazon-web-services), ensure that `KafkaConnect` is enabled under the `Metric Collection` tab.
1. Install the [Datadog - Amazon MSK Connect integration](https://app.datadoghq.com/integrations/amazon-kafka-connect).

## Data Collected{% #data-collected %}

### Metrics{% #metrics %}

|  |
|  |
| **aws.kafkaconnect.bytes\_in\_per\_sec**(gauge)                        | The metadata bytes transferred to the Kafka Connect framework per second for communication between workers.*Shown as byte*   |
| **aws.kafkaconnect.bytes\_out\_per\_sec**(gauge)                       | The metadata bytes transferred from the Kafka Connect framework per second for communication between workers.*Shown as byte* |
| **aws.kafkaconnect.cpu\_utilization**(gauge)                           | The percentage of CPU consumption by system and user.*Shown as percent*                                                      |
| **aws.kafkaconnect.cpu\_utilization.maximum**(gauge)                   | The maximum percentage of CPU consumption by system and user.*Shown as percent*                                              |
| **aws.kafkaconnect.errored\_task\_count**(gauge)                       | The number of tasks that have errored out.*Shown as error*                                                                   |
| **aws.kafkaconnect.memory\_utilization**(gauge)                        | The percentage of total memory utilized on a worker instance.*Shown as percent*                                              |
| **aws.kafkaconnect.memory\_utilization.maximum**(gauge)                | The maximum percentage of total memory utilized on a worker instance.*Shown as percent*                                      |
| **aws.kafkaconnect.rebalance\_completed\_total**(count)                | The total number of rebalances completed by the connector.                                                                   |
| **aws.kafkaconnect.rebalance\_time\_avg**(gauge)                       | The average time spent by the connector on rebalancing.*Shown as millisecond*                                                |
| **aws.kafkaconnect.rebalance\_time\_max**(gauge)                       | The maximum time spent by the connector on rebalancing.*Shown as millisecond*                                                |
| **aws.kafkaconnect.rebalance\_time\_since\_last**(gauge)               | The time since the connector completed the most recent rebalance.*Shown as millisecond*                                      |
| **aws.kafkaconnect.running\_task\_count**(gauge)                       | The number of tasks currently running in the connector.*Shown as task*                                                       |
| **aws.kafkaconnect.running\_task\_count.maximum**(gauge)               | The maximum number of tasks currently running in the connector.*Shown as task*                                               |
| **aws.kafkaconnect.running\_task\_count.minimum**(gauge)               | The minimum number of tasks currently running in the connector.*Shown as task*                                               |
| **aws.kafkaconnect.sink\_consumer\_byte\_rate**(gauge)                 | The average bytes consumed per second by the Kafka Connect Sink consumer before transformations.*Shown as byte*              |
| **aws.kafkaconnect.sink\_record\_read\_rate**(gauge)                   | The average number of records read per second from the Apache Kafka or Amazon MSK cluster.*Shown as record*                  |
| **aws.kafkaconnect.sink\_record\_send\_rate**(gauge)                   | The average number of records per second output from transformations and sent to the destination.*Shown as record*           |
| **aws.kafkaconnect.source\_producer\_byte\_rate**(gauge)               | The average bytes produced per second by the Kafka Connect Source producer after transformations.*Shown as byte*             |
| **aws.kafkaconnect.source\_record\_poll\_rate**(gauge)                 | The average number of records produced or polled per second.*Shown as record*                                                |
| **aws.kafkaconnect.source\_record\_write\_rate**(gauge)                | The average number of records per second output from transformations and written to the cluster.*Shown as record*            |
| **aws.kafkaconnect.task\_startup\_attempts\_total**(count)             | The total number of task startup attempts by the connector.*Shown as task*                                                   |
| **aws.kafkaconnect.task\_startup\_success\_percentage**(gauge)         | The average percentage of successful task starts for the connector.*Shown as percent*                                        |
| **aws.kafkaconnect.task\_startup\_success\_percentage.maximum**(gauge) | The maximum average percentage of successful task starts for the connector.*Shown as percent*                                |
| **aws.kafkaconnect.worker\_count**(gauge)                              | The number of workers running in the connector.*Shown as worker*                                                             |

### Events{% #events %}

The Amazon MSK Connect integration does not include any events.

### Service Checks{% #service-checks %}

The Amazon MSK Connect integration does not include any service checks.

## Troubleshooting{% #troubleshooting %}

Need help? Contact [Datadog support](https://docs.datadoghq.com/help/).