From cbf693f14e3c766f97c9848ab476442c53ff7a7b Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@pivotal.io>
Date: Fri, 6 Apr 2018 12:44:24 -0400
Subject: [PATCH] Fix Stub in mock tests to return the group id

Needed for SK 2.1.5.
---
 .../cloud/stream/binder/kafka/KafkaBinderUnitTests.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java
index 4c018e791..dfc5a6eb7 100644
--- a/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java
+++ b/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderUnitTests.java
@@ -19,6 +19,7 @@ package org.springframework.cloud.stream.binder.kafka;
 import java.lang.reflect.Method;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.CountDownLatch;
@@ -190,8 +191,11 @@ public class KafkaBinderUnitTests {
 
 					@Override
 					public Map<String, Object> getConfigurationProperties() {
-						return Collections.singletonMap(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,
+						Map<String, Object> props = new HashMap<>();
+						props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,
 								earliest ? "earliest" : "latest");
+						props.put(ConsumerConfig.GROUP_ID_CONFIG, "bar");
+						return props;
 					}
 
 				};