search

fd4s / fs2-kafka

Functional Kafka Streams for Scala
https://fd4s.github.io/fs2-kafka
Apache License 2.0
296 stars 101 forks source link

retry CommitTimeoutException #1280

Open razvanz opened 1 year ago

razvanz commented 1 year ago

Is there a particular reason why CommitTimeoutException is not a RetriableCommitFailedException such that the CommitRecovery.Default will retry committing the offsets?