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

INTEXT-180: Fix ListenerContainer fetch pool size

Browse Source 
JIRI: https://jira.spring.io/browse/INTEXT-180
This commit is contained in:
Marius Bogoevici
2015-07-17 12:11:52 -04:00
committed by Artem Bilan
parent 19a27d7759
commit c7f009f544
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/listener/KafkaMessageListenerContainer.java
View File

@@ -306,7 +306,7 @@ public class KafkaMessageListenerContainer implements SmartLifecycle {
partitionsByBrokerMap.clear();
partitionsByBrokerMap.putAll(partitionsAsList.groupBy(getLeader));
if (fetchTaskExecutor == null) {
fetchTaskExecutor = Executors.newFixedThreadPool(partitionsByBrokerMap.size());
fetchTaskExecutor = Executors.newFixedThreadPool(partitionsByBrokerMap.keysView().size());
}
partitionsByBrokerMap.forEachKey(launchFetchTask);
}