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 200e6f9f..67b0c242 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 @@ -630,7 +630,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));