@@ -2437,10 +2437,6 @@ When creating the `TopicPartitionOffset` s for the request, only positive, absol
2437
2437
|BATCH
2438
2438
|Controls how often offsets are committed - see <<committing-offsets>>.
2439
2439
2440
- |[[ackOnError]]<<ackOnError,`ackOnError`>>
2441
- |`false`
2442
- |[DEPRECATED in favor of `ErrorHandler.isAckAfterHandle()`]
2443
-
2444
2440
|[[ackTime]]<<ackTime,`ackTime`>>
2445
2441
|5000
2446
2442
|The time in milliseconds after which pending offsets are committed when the `ackMode` is `TIME` or `COUNT_TIME`.
@@ -5137,7 +5133,6 @@ For example, with the `@KafkaListener` container factory, you can add `DefaultEr
5137
5133
public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
5138
5134
ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory();
5139
5135
factory.setConsumerFactory(consumerFactory());
5140
- factory.getContainerProperties().setAckOnError(false);
5141
5136
factory.getContainerProperties().setAckMode(AckMode.RECORD);
5142
5137
factory.setCommonErrorHandler(new DefaultErrorHandler(new FixedBackOff(1000L, 2L)));
5143
5138
return factory;
@@ -5624,7 +5619,7 @@ DeadLetterPublishingRecoverer recoverer = new DeadLetterPublishingRecoverer(temp
5624
5619
return new TopicPartition(r.topic() + ".other.failures", r.partition());
5625
5620
}
5626
5621
});
5627
- ErrorHandler errorHandler = new DefaultErrorHandler(recoverer, new FixedBackOff(0L, 2L));
5622
+ CommonErrorHandler errorHandler = new DefaultErrorHandler(recoverer, new FixedBackOff(0L, 2L));
5628
5623
----
5629
5624
====
5630
5625
0 commit comments