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 55a3fd5 commit 03f1461Copy full SHA for 03f1461
spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -566,7 +566,10 @@ else if (KafkaMessageListenerContainer.this.getContainerProperties().isSyncCommi
566
};
567
}
568
569
- private void seekPartitions(Collection<TopicPartition> partitions, boolean idle) {
+ private void seekPartitions(@Nullable Collection<TopicPartition> partitions, boolean idle) {
570
+ if (partitions == null) {
571
+ return;
572
+ }
573
Map<TopicPartition, Long> current = new HashMap<>();
574
for (TopicPartition topicPartition : partitions) {
575
current.put(topicPartition, ListenerConsumer.this.consumer.position(topicPartition));
0 commit comments