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
         };
     }