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

GH-1145: Backport NPE Fix

Browse Source 
Resolves https://github.com/spring-projects/spring-kafka/issues/1145

**cherry-pick to 2.0.x, 1.3.x**
This commit is contained in:
Gary Russell
2019-06-27 12:13:08 -04:00
committed by Artem Bilan
parent bb06d194f6
commit 65741531bb
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -562,7 +562,10 @@ public class KafkaMessageListenerContainer<K, V> extends AbstractMessageListener
};
}
private void seekPartitions(Collection<TopicPartition> partitions, boolean idle) {
private void seekPartitions(@Nullable Collection<TopicPartition> partitions, boolean idle) {
if (partitions == null) {
return;
}
Map<TopicPartition, Long> current = new HashMap<>();
for (TopicPartition topicPartition : partitions) {
current.put(topicPartition, ListenerConsumer.this.consumer.position(topicPartition));