diff --git a/src/JT808.DotNetty.Kafka/JT808MsgConsumer.cs b/src/JT808.DotNetty.Kafka/JT808MsgConsumer.cs
index 2545d45..4dbce74 100644
--- a/src/JT808.DotNetty.Kafka/JT808MsgConsumer.cs
+++ b/src/JT808.DotNetty.Kafka/JT808MsgConsumer.cs
@@ -12,7 +12,7 @@ namespace JT808.DotNetty.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.DotNetty.Kafka/JT808MsgReplyConsumer.cs b/src/JT808.DotNetty.Kafka/JT808MsgReplyConsumer.cs
index 9f3f49c..e3aea34 100644
--- a/src/JT808.DotNetty.Kafka/JT808MsgReplyConsumer.cs
+++ b/src/JT808.DotNetty.Kafka/JT808MsgReplyConsumer.cs
@@ -12,7 +12,7 @@ namespace JT808.DotNetty.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.DotNetty.Kafka/JT808SessionConsumer.cs b/src/JT808.DotNetty.Kafka/JT808SessionConsumer.cs
index d4080d7..587976a 100644
--- a/src/JT808.DotNetty.Kafka/JT808SessionConsumer.cs
+++ b/src/JT808.DotNetty.Kafka/JT808SessionConsumer.cs
@@ -12,7 +12,7 @@ namespace JT808.DotNetty.Kafka
 {
     public class JT808SessionConsumer : IJT808SessionConsumer
     {
-        public CancellationTokenSource Cts => new CancellationTokenSource();
+        public CancellationTokenSource Cts { get; private set; } = new CancellationTokenSource();
 
         private readonly IConsumer<string, string> consumer;