Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix definedPartitionsTest

Browse Source 
Change lost during cherry-pick.
This commit is contained in:
Gary Russell
2017-04-26 10:52:40 -04:00
parent cbd7788ed8
commit b65f077a61
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java
View File

@@ -248,7 +248,7 @@ public class ConcurrentMessageListenerContainerTests {
DefaultKafkaConsumerFactory<Integer, String> cf = new DefaultKafkaConsumerFactory<Integer, String>(props) {
@Override
public Consumer<Integer, String> createConsumer() {
public Consumer<Integer, String> createConsumer(String clientIdSuffix) {
return new KafkaConsumer<Integer, String>(props) {
@Override