diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java index d9d45ffb..b7ada6aa 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java @@ -562,7 +562,10 @@ public class KafkaMessageListenerContainer extends AbstractMessageListener }; } - private void seekPartitions(Collection partitions, boolean idle) { + private void seekPartitions(@Nullable Collection partitions, boolean idle) { + if (partitions == null) { + return; + } Map current = new HashMap<>(); for (TopicPartition topicPartition : partitions) { current.put(topicPartition, ListenerConsumer.this.consumer.position(topicPartition));