From ee79a1c632138fe5a6f79085e269005c628a8f81 Mon Sep 17 00:00:00 2001 From: sean-madden <30605997+sean-madden@users.noreply.github.com> Date: Thu, 10 Sep 2020 16:42:22 -0700 Subject: [PATCH] GH-173: Use DEFAULT_DDB_BILLING_MODE instead of null Fixes https://github.com/spring-projects/spring-integration-aws/issues/173 --- .../aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java index 44fea62..ad6a4d4 100644 --- a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java +++ b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java @@ -293,7 +293,9 @@ public class KclMessageDrivenChannelAdapter extends MessageProducerSupport { KinesisClientLibConfiguration.DEFAULT_METRICS_MAX_QUEUE_SIZE, KinesisClientLibConfiguration.DEFAULT_VALIDATE_SEQUENCE_NUMBER_BEFORE_CHECKPOINTING, null, - KinesisClientLibConfiguration.DEFAULT_SHUTDOWN_GRACE_MILLIS, null); + KinesisClientLibConfiguration.DEFAULT_SHUTDOWN_GRACE_MILLIS, + KinesisClientLibConfiguration.DEFAULT_DDB_BILLING_MODE + ); } this.consumerGroup = this.config.getApplicationName();