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

Add nullability changes in core/reactive package

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

Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
This commit is contained in:
Soby Chacko
2025-02-25 18:27:31 -05:00
parent 0e9d3d341a
commit efd348465a
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-kafka/src/main/java/org/springframework/kafka/core/reactive/ReactiveKafkaConsumerTemplate.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2019-2024 the original author or authors.
* Copyright 2019-2025 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -131,6 +131,7 @@ public class ReactiveKafkaConsumerTemplate<K, V> {
return subscriptions.flatMapIterable(Function.identity());
}
@SuppressWarnings("NullAway") // Lambda
public Mono<Void> seek(TopicPartition partition, long offset) {
return doOnConsumer(consumer -> {
consumer.seek(partition, offset);
@@ -138,6 +139,7 @@ public class ReactiveKafkaConsumerTemplate<K, V> {
});
}
@SuppressWarnings("NullAway") // Lambda
public Mono<Void> seekToBeginning(TopicPartition... partitions) {
return doOnConsumer(consumer -> {
consumer.seekToBeginning(Arrays.asList(partitions));
@@ -145,6 +147,7 @@ public class ReactiveKafkaConsumerTemplate<K, V> {
});
}
@SuppressWarnings("NullAway") // Lambda
public Mono<Void> seekToEnd(TopicPartition... partitions) {
return doOnConsumer(consumer -> {
consumer.seekToEnd(Arrays.asList(partitions));
@@ -170,6 +173,7 @@ public class ReactiveKafkaConsumerTemplate<K, V> {
return paused.flatMapIterable(Function.identity());
}
@SuppressWarnings("NullAway") // Lambda
public Mono<Void> pause(TopicPartition... partitions) {
return doOnConsumer(c -> {
c.pause(Arrays.asList(partitions));
@@ -177,6 +181,7 @@ public class ReactiveKafkaConsumerTemplate<K, V> {
});
}
@SuppressWarnings("NullAway") // Lambda
public Mono<Void> resume(TopicPartition... partitions) {
return doOnConsumer(c -> {
c.resume(Arrays.asList(partitions));