From b65f077a6141144da1ff59f6c6f80f736d30d751 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 26 Apr 2017 10:52:40 -0400 Subject: [PATCH] Fix definedPartitionsTest Change lost during cherry-pick. --- .../kafka/listener/ConcurrentMessageListenerContainerTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java b/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java index 04d182ee..47501c80 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java @@ -248,7 +248,7 @@ public class ConcurrentMessageListenerContainerTests { DefaultKafkaConsumerFactory cf = new DefaultKafkaConsumerFactory(props) { @Override - public Consumer createConsumer() { + public Consumer createConsumer(String clientIdSuffix) { return new KafkaConsumer(props) { @Override