diff --git a/modules/JiShe.CollectBus.Kafka/KafkaSubcribesExtensions.cs b/modules/JiShe.CollectBus.Kafka/KafkaSubcribesExtensions.cs index fa26e53..52e5c93 100644 --- a/modules/JiShe.CollectBus.Kafka/KafkaSubcribesExtensions.cs +++ b/modules/JiShe.CollectBus.Kafka/KafkaSubcribesExtensions.cs @@ -182,7 +182,9 @@ namespace JiShe.CollectBus.Kafka { try { +#if DEBUG logger.LogInformation($"kafka批量消费消息:{message}"); +#endif // 处理消息 return await ProcessMessageAsync(message.ToList(), method, subscribe); }