modules/JiShe.CollectBus.Kafka/Consumer/ConsumerService.cs

@@ -183,11 +183,6 @@ namespace JiShe.CollectBus.Kafka.Consumer
                             _logger.LogError(ex, $"{string.Join("、", topics)}消息消费失败: {ex.Error.Reason}");
                             throw; // 抛出异常，以便重试
                         }
-                        catch (KafkaException ex) when (KafkaPollyPipeline.IsRecoverableError(ex))
-                        {
-                            _logger.LogError(ex, $"{string.Join("、", topics)} 消息消费失败: {ex.Error.Reason}");
-                            throw; // 抛出异常，以便重试
-                        }
                         catch (OperationCanceledException)
                         {
                             //ignore
@@ -408,18 +403,13 @@ namespace JiShe.CollectBus.Kafka.Consumer
                             _logger.LogError(ex, $"{string.Join("、", topics)} 消息消费失败: {ex.Error.Reason}");
                             throw; // 抛出异常，以便重试
                         }
-                        catch (KafkaException ex) when (KafkaPollyPipeline.IsRecoverableError(ex))
-                        {
-                            _logger.LogError(ex, $"{string.Join("、", topics)} 消息消费失败: {ex.Error.Reason}");
-                            throw; // 抛出异常，以便重试
-                        }
                         catch (OperationCanceledException)
                         {
                             //ignore
                         }
                         catch (Exception ex)
                         {
-                           _logger.LogError(ex, "处理批量消息时发生未知错误");
+                            _logger.LogError(ex, "处理批量消息时发生未知错误");
                         }
                     }
                 }, cts.Token);
@@ -550,18 +540,13 @@ namespace JiShe.CollectBus.Kafka.Consumer
                             _logger.LogError(ex, $"消息消费失败: {ex.Error.Reason}");
                             throw; // 抛出异常，以便重试
                         }
-                        catch (KafkaException ex) when (KafkaPollyPipeline.IsRecoverableError(ex))
-                        {
-                            _logger.LogError(ex, $"{string.Join("、", topics)} 消息消费失败: {ex.Error.Reason}");
-                            throw; // 抛出异常，以便重试
-                        }
                         catch (OperationCanceledException)
                         {
                             //ignore
                         }
                         catch (Exception ex)
                         {
-                           _logger.LogError(ex, "处理批量消息时发生未知错误");
+                            _logger.LogError(ex, "处理批量消息时发生未知错误");
                         }
                     }
                 }, cts.Token);