diff --git a/src/JT808.Gateway.Kafka/JT808MsgConsumer.cs b/src/JT808.Gateway.Kafka/JT808MsgConsumer.cs
index da9d71e..7fd4496 100644
--- a/src/JT808.Gateway.Kafka/JT808MsgConsumer.cs
+++ b/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;
 
diff --git a/src/JT808.Gateway.Kafka/JT808MsgReplyConsumer.cs b/src/JT808.Gateway.Kafka/JT808MsgReplyConsumer.cs
index 340fd30..deb9958 100644
--- a/src/JT808.Gateway.Kafka/JT808MsgReplyConsumer.cs
+++ b/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;
 
diff --git a/src/JT808.Gateway.Kafka/JT808SessionConsumer.cs b/src/JT808.Gateway.Kafka/JT808SessionConsumer.cs
index 83b4d31..1df01d3 100644
--- a/src/JT808.Gateway.Kafka/JT808SessionConsumer.cs
+++ b/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;