From b741f607b0e7c4bb654156acccb54005a68c8d40 Mon Sep 17 00:00:00 2001
From: Nikita Myazin <myazin.n@list.ru>
Date: Wed, 20 Dec 2023 14:55:00 +0300
Subject: [PATCH] retry Consumer.CommitTimeout exception (#1140)

---
 zio-kafka/src/main/scala/zio/kafka/consumer/Offset.scala | 1 +
 1 file changed, 1 insertion(+)

diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/Offset.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/Offset.scala
index c0cd0b65c9..07907e8ffe 100644
--- 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
     )