Skip to content

Commit ad08a14

Browse files
chanhyeonggaryrussell
authored andcommitted
add nullable annotation to FailedRecordTracker.setBackOffFunction
1 parent babfa51 commit ad08a14

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/FailedRecordTracker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ class FailedRecordTracker implements RecoveryStrategy {
9898
* @param backOffFunction the function.
9999
* @since 2.6
100100
*/
101-
public void setBackOffFunction(BiFunction<ConsumerRecord<?, ?>, Exception, BackOff> backOffFunction) {
101+
public void setBackOffFunction(@Nullable BiFunction<ConsumerRecord<?, ?>, Exception, BackOff> backOffFunction) {
102102
this.backOffFunction = backOffFunction;
103103
}
104104

0 commit comments

Comments
 (0)