From ebbe5f054d98291c11d84540bebf4eef9fde5b86 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Tue, 3 Apr 2018 12:23:59 -0400
Subject: [PATCH] Fix KafkaMesListenerContTests for proper mocks

https://build.spring.io/browse/SK-SK20X-34/

**Cherry-pick to 1.3.x**

# Conflicts:
#	spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
---
 .../kafka/listener/KafkaMessageListenerContainerTests.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java b/spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
index 61aa4f2d90..52dd2ef26b 100644
--- a/spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
+++ b/spring-kafka/src/test/java/org/springframework/kafka/listener/KafkaMessageListenerContainerTests.java
@@ -435,7 +435,7 @@ public void publishEvent(ApplicationEvent event) {
 	public void testNonResponsiveConsumerEventNotIssuedWithActiveConsumer() throws Exception {
 		ConsumerFactory<Integer, String> cf = mock(ConsumerFactory.class);
 		Consumer<Integer, String> consumer = mock(Consumer.class);
-		given(cf.createConsumer(anyString(), eq(""))).willReturn(consumer);
+		given(cf.createConsumer(anyString(), anyString())).willReturn(consumer);
 		ConsumerRecords records = new ConsumerRecords(Collections.emptyMap());
 		CountDownLatch latch = new CountDownLatch(20);
 		given(consumer.poll(anyLong())).willAnswer(i -> {