diff --git a/modules/JiShe.CollectBus.Kafka/Internal/KafkaPollyPipeline.cs b/modules/JiShe.CollectBus.Kafka/Internal/KafkaPollyPipeline.cs index 9750f86..6f1e4fd 100644 --- a/modules/JiShe.CollectBus.Kafka/Internal/KafkaPollyPipeline.cs +++ b/modules/JiShe.CollectBus.Kafka/Internal/KafkaPollyPipeline.cs @@ -33,7 +33,8 @@ namespace JiShe.CollectBus.Kafka.Internal ErrorCode.RebalanceInProgress, ErrorCode.NotCoordinatorForGroup, ErrorCode.NetworkException, - ErrorCode.GroupCoordinatorNotAvailable + ErrorCode.GroupCoordinatorNotAvailable, + ErrorCode.InvalidGroupId }; return ex switch {