diff --git a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
index e4fe0bb..800c5c2 100644
--- a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
+++ b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
@@ -552,9 +552,11 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
 						}
 					}
 
-					ConsumerInvoker firstConsumerInvoker = this.consumerInvokers.get(0);
-					firstConsumerInvoker.addConsumer(shardConsumer);
-					this.consumerInvokerMaxCapacity = firstConsumerInvoker.consumers.size();
+					if (this.concurrency != 0) {
+						ConsumerInvoker firstConsumerInvoker = this.consumerInvokers.get(0);
+						firstConsumerInvoker.addConsumer(shardConsumer);
+						this.consumerInvokerMaxCapacity = firstConsumerInvoker.consumers.size();
+					}
 				}
 			}
 		}