Skip to content

Commit cb1fe22

Browse files
committed
1 parent 5e32ad9 commit cb1fe22

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ public void setCommitRecovered(boolean commitRecovered) {
112112
* Set to false to immediately attempt to recover on the next attempt instead
113113
* of repeating the BackOff cycle when recovery fails.
114114
* @param resetStateOnRecoveryFailure false to retain state.
115-
* @since 3.5.5
115+
* @since 2.5.5
116116
*/
117117
public void setResetStateOnRecoveryFailure(boolean resetStateOnRecoveryFailure) {
118118
this.failureTracker.setResetStateOnRecoveryFailure(resetStateOnRecoveryFailure);

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
@@ -79,7 +79,7 @@ class FailedRecordTracker {
7979
* Set to false to immediately attempt to recover on the next attempt instead
8080
* of repeating the BackOff cycle when recovery fails.
8181
* @param resetStateOnRecoveryFailure false to retain state.
82-
* @since 3.5.5
82+
* @since 2.5.5
8383
*/
8484
public void setResetStateOnRecoveryFailure(boolean resetStateOnRecoveryFailure) {
8585
this.resetStateOnRecoveryFailure = resetStateOnRecoveryFailure;

0 commit comments

Comments
 (0)