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();