Skip to content

Commit

Permalink
Merge branch 'master' into faster-tests
Browse files Browse the repository at this point in the history
  • Loading branch information
erikvanoosten authored Dec 20, 2023
2 parents 57192de + b741f60 commit 51cff6f
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions zio-kafka/src/main/scala/zio/kafka/consumer/Offset.scala
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@ object Offset {
commit.retry(
Schedule.recurWhile[Throwable] {
case _: RetriableCommitFailedException => true
case Consumer.CommitTimeout => true
case _ => false
} && policy
)
Expand Down

0 comments on commit 51cff6f

Please sign in to comment.