diff --git a/build.gradle b/build.gradle
index 2bbcf05..24668ea 100644
--- a/build.gradle
+++ b/build.gradle
@@ -38,7 +38,7 @@ ext {
 	servletApiVersion = '6.0.0'
 	log4jVersion = '2.19.0'
 	springCloudAwsVersion = '3.0.0-RC1'
-	springIntegrationVersion = '6.1.0-SNAPSHOT'
+	springIntegrationVersion = '6.0.4'
 	kinesisClientVersion = '2.4.5'
 	kinesisProducerVersion = '0.15.5'
 	testcontainersVersion = '1.17.6'
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 3a97c5c..c3f1107 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
@@ -144,6 +144,7 @@ public class KclMessageDrivenChannelAdapter extends MessageProducerSupport {
 		Assert.notNull(kinesisClient, "'kinesisClient' must not be null.");
 		Assert.notNull(cloudWatchClient, "'cloudWatchClient' must not be null.");
 		Assert.notNull(dynamoDBClient, "'dynamoDBClient' must not be null.");
+		Assert.notEmpty(streams, "'streams' must not be empty.");
 		this.streams = streams;
 		this.kinesisClient = kinesisClient;
 		this.cloudWatchClient = cloudWatchClient;