--- title: Amazon Kinesis Data Analytics description: >- Easily transform, query, and analyze streaming data in real-time using Apache Flink and Amazon Kinesis Data Analytics. breadcrumbs: Docs > Integrations > Amazon Kinesis Data Analytics --- # Amazon Kinesis Data Analytics Integration version1.0.0 ## Overview{% #overview %} Amazon Kinesis Data Analytics enables you to easily transform, query, and analyze streaming data in real-time using Apache Flink. Enable this integration to see all your Amazon Kinesis Data Analytics 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/) first. ### Metric collection{% #metric-collection %} 1. In the [AWS integration page](https://app.datadoghq.com/integrations/amazon-web-services), ensure that `Kinesis Analytics` is enabled under the `Metric Collection` tab. 1. Install the [Datadog - Amazon Kinesis Data Analytics integration](https://app.datadoghq.com/integrations/amazon-kinesis-data-analytics). ## Data Collected{% #data-collected %} ### Metrics{% #metrics %} | | | | | **aws.kinesisanalytics.bytes**(count) | The number of bytes read (per input stream) or written (per output stream).*Shown as byte* | | **aws.kinesisanalytics.cpu\_utilization**(gauge) | The overall average percentage of CPU utilization across task managers.*Shown as percent* | | **aws.kinesisanalytics.cpu\_utilization.maximum**(gauge) | The overall maximum percentage of CPU utilization across task managers.*Shown as percent* | | **aws.kinesisanalytics.input\_processing\_dropped\_records**(count) | The number of records returned by the input processing Lambda function that were marked with Dropped status.*Shown as record* | | **aws.kinesisanalytics.input\_processing\_duration**(gauge) | The average time taken for an input processing Lambda function invocation performed by Kinesis Data Analytics.*Shown as millisecond* | | **aws.kinesisanalytics.input\_processing\_duration.maximum**(gauge) | The maximum time taken for an input processing Lambda function invocation performed by Kinesis Data Analytics.*Shown as millisecond* | | **aws.kinesisanalytics.input\_processing\_duration.minimum**(gauge) | The minimum time taken for an input processing Lambda function invocation performed by Kinesis Data Analytics.*Shown as millisecond* | | **aws.kinesisanalytics.input\_processing\_ok\_bytes**(count) | The sum of bytes of the records returned by the input processing Lambda function that were marked with Ok status.*Shown as byte* | | **aws.kinesisanalytics.input\_processing\_ok\_records**(count) | The number of records returned by the input processing Lambda function that were marked with Ok status.*Shown as record* | | **aws.kinesisanalytics.input\_processing\_processing\_failed\_records**(count) | The number of records returned by the input processing Lambda function that were marked with ProcessingFailed status.*Shown as record* | | **aws.kinesisanalytics.input\_processing\_success**(count) | The number of successful input processing Lambda invocations by Kinesis Data Analytics.*Shown as invocation* | | **aws.kinesisanalytics.input\_processing\_success.average**(gauge) | The fraction of input processing Lambda invocations that were successful.*Shown as fraction* | | **aws.kinesisanalytics.kpus**(count) | The number of Kinesis Processing Units that are used to run your stream processing application.*Shown as unit* | | **aws.kinesisanalytics.kpus.average**(gauge) | The average number of Kinesis Processing Units that are used to run your stream processing application. The average number of KPUs used each hour determines the billing for your application.*Shown as unit* | | **aws.kinesisanalytics.lambda\_delivery\_delivery\_failed\_records**(count) | The number of records returned by a delivery Lambda function that were marked with DeliveryFailed status.*Shown as record* | | **aws.kinesisanalytics.lambda\_delivery\_duration**(gauge) | The average time taken for a delivery Lambda function invocation performed by Kinesis Data Analytics.*Shown as millisecond* | | **aws.kinesisanalytics.lambda\_delivery\_duration.maximum**(gauge) | The maximum time taken for a delivery Lambda function invocation performed by Kinesis Data Analytics.*Shown as millisecond* | | **aws.kinesisanalytics.lambda\_delivery\_duration.minimum**(gauge) | The minimum time taken for a delivery Lambda function invocation performed by Kinesis Data Analytics.*Shown as millisecond* | | **aws.kinesisanalytics.lambda\_delivery\_ok\_records**(count) | The number of records returned by a delivery Lambda function that were marked with Ok status.*Shown as record* | | **aws.kinesisanalytics.millis\_behind\_latest**(gauge) | The average duration in milliseconds behind the current time that the application was reading from the streaming source.*Shown as millisecond* | | **aws.kinesisanalytics.millis\_behind\_latest.maximum**(gauge) | The maximum duration in milliseconds behind the current time that the application was reading from the streaming source*Shown as millisecond* | | **aws.kinesisanalytics.millis\_behind\_latest.minimum**(gauge) | The minimum duration in milliseconds behind the current time that the application was reading from the streaming source.*Shown as millisecond* | | **aws.kinesisanalytics.records**(count) | The number of records read (per input stream) or written (per output stream).*Shown as record* | | **aws.kinesisanalytics.success**(count) | The number of successful delivery attempts to the destination configured for your application.*Shown as unit* | | **aws.kinesisanalytics.success.average**(gauge) | The fraction of delivery attempts to the destination configured for your application that are successful.*Shown as fraction* | ### Events{% #events %} The Amazon Kinesis Data Analytics integration does not include any events. ### Service Checks{% #service-checks %} The Amazon Kinesis Data Analytics integration does not include any service checks. ## Troubleshooting{% #troubleshooting %} Need help? Contact [Datadog support](https://docs.datadoghq.com/help/).