From f74bedd3cdfeb49dc389c3642e8b6519e3558834 Mon Sep 17 00:00:00 2001
From: zenghongyao <873884283@qq.com>
Date: Tue, 15 Apr 2025 15:50:30 +0800
Subject: [PATCH] =?UTF-8?q?=E7=89=B9=E6=80=A7=E8=AE=A2=E9=98=85=E6=A1=88?=
 =?UTF-8?q?=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/JiShe.CollectBus.Application/Samples/SampleAppService.cs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs b/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
index e9ce063..e8b483d 100644
--- a/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
+++ b/src/JiShe.CollectBus.Application/Samples/SampleAppService.cs
@@ -186,9 +186,9 @@ public class SampleAppService : CollectBusAppService, ISampleAppService, IKafkaS
 
     [KafkaSubscribe(["test-topic"])]
 
-    public async Task KafkaSubscribeAsync(string obj)
+    public async Task<bool> KafkaSubscribeAsync(string obj)
     {
         _logger.LogWarning($"收到订阅消息： {obj}");
-        await Task.CompletedTask;
+       return await Task.FromResult(true);
     }
 }