Async commits associated to a KafkaListener are not retried in case of RetriableCommitFailedException

Question

Async commits associated to a KafkaListener are not retried in case of RetriableCommitFailedException whereas this is the case for sync commits (based on ContainerProperties#commitRetries).

Is there any reason/constraint not to do this for asynchronous commits as well?

Gary Russell · Answer

It caused problems because we ended up committing old offsets for partitions that already had later offsets committed. It could also cause stack overflows with large failure rates.

https://github.com/spring-projects/spring-kafka/pull/2088

Async commits associated to a KafkaListener are not retried in case of RetriableCommitFailedException

1 Answers