retry Consumer.CommitTimeout exception (#1140)

zio · Dec 20, 2023 · b741f60 · b741f60
1 parent 079a74f
commit b741f60
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/Offset.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/Offset.scala
@@ -35,6 +35,7 @@ object Offset {
     commit.retry(
       Schedule.recurWhile[Throwable] {
         case _: RetriableCommitFailedException => true
+        case Consumer.CommitTimeout            => true
         case _                                 => false
       } && policy
     )