From c93feb631d62340a534d617946542ea6e6caa384 Mon Sep 17 00:00:00 2001 From: zenghongyao <873884283@qq.com> Date: Fri, 18 Apr 2025 08:23:31 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E9=98=85=E7=89=B9=E6=80=A7=E4=BC=98?= =?UTF-8?q?=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/JiShe.CollectBus.Kafka/KafkaSubcribesExtensions.cs | 2 ++ 1 file changed, 2 insertions(+) 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); }