From 7cb2aedadbafb7b240d4b9be07688ed460f28ebe Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Wed, 9 Oct 2024 10:42:56 +0800
Subject: [PATCH] Add more default retryable error codes for Kakfa consumption
 exceptions. #1587

---
 src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs b/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs
index 6362d2fef..15acb36d4 100644
--- a/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs
+++ b/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs
@@ -26,7 +26,16 @@ public KafkaOptions()
         MainConfig = new Dictionary<string, string>();
         RetriableErrorCodes = new List<ErrorCode>
         {
-            ErrorCode.GroupLoadInProgress
+            ErrorCode.GroupLoadInProgress,
+            ErrorCode.Local_Retry,
+            ErrorCode.RequestTimedOut,
+            ErrorCode.LeaderNotAvailable,
+            ErrorCode.NotLeaderForPartition,
+            ErrorCode.RebalanceInProgress,
+            ErrorCode.NotCoordinatorForGroup,
+            ErrorCode.NetworkException,
+            ErrorCode.GroupCoordinatorNotAvailable,
+            ErrorCode.Local_MaxPollExceeded
         };
     }