@@ -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
51115107public 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