特性订阅案例

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);
     }
 }