From 5c3537d756bbdcc9cf6d83d3f926b88fe3a2ec4b Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Thu, 26 Dec 2019 14:40:20 -0500
Subject: [PATCH] Expose `KclMDChannelAdapter.getConsumerGroup()`

---
 .../aws/inbound/kinesis/KclMessageDrivenChannelAdapter.java   | 4 ++++
 1 file changed, 4 insertions(+)

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.