修复消费者中CancellationTokenSource每次调用时重新创建

src/JT808.Gateway.Kafka/JT808MsgConsumer.cs

@@ -13,7 +13,7 @@ namespace JT808.Gateway.Kafka
 {
     public class JT808MsgConsumer : IJT808MsgConsumer
     {
-        public CancellationTokenSource Cts => new CancellationTokenSource();
+        public CancellationTokenSource Cts { get; private set; } = new CancellationTokenSource();
 
         private readonly IConsumer<string, byte[]> consumer;
 

src/JT808.Gateway.Kafka/JT808MsgReplyConsumer.cs

@@ -13,7 +13,7 @@ namespace JT808.Gateway.Kafka
 {
     public class JT808MsgReplyConsumer : IJT808MsgReplyConsumer
     {
-        public CancellationTokenSource Cts => new CancellationTokenSource();
+        public CancellationTokenSource Cts { get; private set; } = new CancellationTokenSource();
 
         private readonly IConsumer<string, byte[]> consumer;
 

src/JT808.Gateway.Kafka/JT808SessionConsumer.cs

@@ -13,7 +13,7 @@ namespace JT808.Gateway.Kafka
 {
     public class JT808SessionConsumer : IJT808SessionConsumer
     {
-        public CancellationTokenSource Cts => new CancellationTokenSource();
+        public CancellationTokenSource Cts { get; private set; } = new CancellationTokenSource();
 
         private readonly IConsumer<string, string> consumer;