Skip to content

Commit 9248d83

Browse files
committed
GH-2286: Doc Fixes
Resolves #2286 Remove `ackOnError` and fix error handler type.
1 parent ea3dd76 commit 9248d83

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

spring-kafka-docs/src/main/asciidoc/kafka.adoc

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2437,10 +2437,6 @@ When creating the `TopicPartitionOffset` s for the request, only positive, absol
24372437
|BATCH
24382438
|Controls how often offsets are committed - see <<committing-offsets>>.
24392439

2440-
|[[ackOnError]]<<ackOnError,`ackOnError`>>
2441-
|`false`
2442-
|[DEPRECATED in favor of `ErrorHandler.isAckAfterHandle()`]
2443-
24442440
|[[ackTime]]<<ackTime,`ackTime`>>
24452441
|5000
24462442
|The time in milliseconds after which pending offsets are committed when the `ackMode` is `TIME` or `COUNT_TIME`.
@@ -5111,7 +5107,6 @@ For example, with the `@KafkaListener` container factory, you can add `DefaultEr
51115107
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
51125108
ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory();
51135109
factory.setConsumerFactory(consumerFactory());
5114-
factory.getContainerProperties().setAckOnError(false);
51155110
factory.getContainerProperties().setAckMode(AckMode.RECORD);
51165111
factory.setCommonErrorHandler(new DefaultErrorHandler(new FixedBackOff(1000L, 2L)));
51175112
return factory;
@@ -5598,7 +5593,7 @@ DeadLetterPublishingRecoverer recoverer = new DeadLetterPublishingRecoverer(temp
55985593
return new TopicPartition(r.topic() + ".other.failures", r.partition());
55995594
}
56005595
});
5601-
ErrorHandler errorHandler = new DefaultErrorHandler(recoverer, new FixedBackOff(0L, 2L));
5596+
CommonErrorHandler errorHandler = new DefaultErrorHandler(recoverer, new FixedBackOff(0L, 2L));
56025597
----
56035598
====
56045599

0 commit comments

Comments
 (0)