From c93a4cc169dc89b3214c5ec0a3547f4df28d51b9 Mon Sep 17 00:00:00 2001
From: "J. Schwerer" <101340023+j-schwerer@users.noreply.github.com>
Date: Tue, 16 Aug 2022 10:04:03 +0100
Subject: [PATCH] Update DefaultCWMetricsPublisher.java

Adapting to the new CloudWatch API batch max size - cf. https://aws.amazon.com/about-aws/whats-new/2022/08/amazon-cloudwatch-metrics-increases-throughput/
---
 .../kinesis/metrics/impl/DefaultCWMetricsPublisher.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/amazonaws/services/kinesis/metrics/impl/DefaultCWMetricsPublisher.java b/src/main/java/com/amazonaws/services/kinesis/metrics/impl/DefaultCWMetricsPublisher.java
index 45ae8e27..c3ddb96a 100644
--- a/src/main/java/com/amazonaws/services/kinesis/metrics/impl/DefaultCWMetricsPublisher.java
+++ b/src/main/java/com/amazonaws/services/kinesis/metrics/impl/DefaultCWMetricsPublisher.java
@@ -33,8 +33,8 @@ public class DefaultCWMetricsPublisher implements ICWMetricsPublisher<CWMetricKe
 
     private static final Log LOG = LogFactory.getLog(CWPublisherRunnable.class);
 
-    // CloudWatch API has a limit of 20 MetricDatums per request
-    private static final int BATCH_SIZE = 20;
+    // CloudWatch API has a limit of 1000 MetricDatums per request
+    private static final int BATCH_SIZE = 1000;
 
     private final String namespace;
     private final AmazonCloudWatch cloudWatchClient;