Add more default retryable error codes for Kakfa consumption exceptio…

…ns. #1587
dotnetcore · Oct 9, 2024 · 7cb2aed · 7cb2aed
1 parent d2f25eb
commit 7cb2aed
Showing 1 changed file with 10 additions and 1 deletion.
diff --git 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
         };
     }