src/JiShe.CollectBus.Application/Samples/SampleAppService.cs

@@ -265,7 +265,7 @@ public class SampleAppService : CollectBusAppService, ISampleAppService, IKafkaS
         return aa == null;
     }
 
-    //[KafkaSubscribe("test-topic1")]
+    [KafkaSubscribe(ProtocolConst.TESTTOPIC)]
 
     public async Task<ISubscribeAck> KafkaSubscribeAsync(object obj)
     {

src/JiShe.CollectBus.Common/Consts/ProtocolConst.cs

@@ -159,5 +159,11 @@ namespace JiShe.CollectBus.Common.Consts
         /// AFN10H上行主题格式
         /// </summary>
         public const string SubscriberAFN10HReceivedEventNameTemp = "received.afn16h.event";
+
+
+        /// <summary>
+        /// 测试主题格式
+        /// </summary>
+        public const string TESTTOPIC = "test-topic";
     }
 }