We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1171c00 commit 15ab184Copy full SHA for 15ab184
spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -630,7 +630,10 @@ else if (KafkaMessageListenerContainer.this.getContainerProperties().isSyncCommi
630
};
631
}
632
633
- private void seekPartitions(Collection<TopicPartition> partitions, boolean idle) {
+ private void seekPartitions(@Nullable Collection<TopicPartition> partitions, boolean idle) {
634
+ if (partitions == null) {
635
+ return;
636
+ }
637
Map<TopicPartition, Long> current = new HashMap<>();
638
for (TopicPartition topicPartition : partitions) {
639
current.put(topicPartition, ListenerConsumer.this.consumer.position(topicPartition));
0 commit comments