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 1d62e80..5bded3d 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
@@ -183,6 +183,10 @@ public class KclMessageDrivenChannelAdapter extends MessageProducerSupport {
 		this.consumerGroup = consumerGroup;
 	}
 
+	public String getConsumerGroup() {
+		return this.consumerGroup;
+	}
+
 	/**
 	 * Specify an {@link InboundMessageMapper} to extract message headers embedded into
 	 * the record data.