Add more default retryable error codes for Kakfa consumption exceptions. #1587

yang-xiaodong · yang-xiaodong · commit 129ffd59d4be · 2024-10-09T10:43:44.000+08:00
diff --git a/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs b/src/DotNetCore.CAP.Kafka/CAP.KafkaOptions.cs
@@ -34,8 +34,7 @@ public KafkaOptions()
             ErrorCode.RebalanceInProgress,
             ErrorCode.NotCoordinatorForGroup,
             ErrorCode.NetworkException,
-            ErrorCode.GroupCoordinatorNotAvailable,
-            ErrorCode.Local_MaxPollExceeded
+            ErrorCode.GroupCoordinatorNotAvailable
         };
     }
 

Original file line number	Diff line number	Diff line change
`@@ -34,8 +34,7 @@ public KafkaOptions()`
`34`	`34`	`ErrorCode.RebalanceInProgress,`
`35`	`35`	`ErrorCode.NotCoordinatorForGroup,`
`36`	`36`	`ErrorCode.NetworkException,`
`37`		`- ErrorCode.GroupCoordinatorNotAvailable,`
`38`		`- ErrorCode.Local_MaxPollExceeded`
	`37`	`+ ErrorCode.GroupCoordinatorNotAvailable`
`39`	`38`	`};`
`40`	`39`	`}`
`41`	`40`