diff --git a/src/Cap.Consistency.Kafka/KafkaConsumerClient.cs b/src/Cap.Consistency.Kafka/KafkaConsumerClient.cs
index 2e5e47a..0d3f396 100644
--- a/src/Cap.Consistency.Kafka/KafkaConsumerClient.cs
+++ b/src/Cap.Consistency.Kafka/KafkaConsumerClient.cs
@@ -9,14 +9,7 @@ using Confluent.Kafka.Serialization;
 
 namespace Cap.Consistency.Kafka
 {
-    public class KafkaTopicPartition
-    {
-        public string Topic { get; set; }
-
-        public int Partition { get; set; }
-    }
-
-    public class KafkaConsumerClient : IConsumerClient, IDisposable
+    public class KafkaConsumerClient : IConsumerClient
     {
 
         private readonly string _groupId;
@@ -47,22 +40,6 @@ namespace Cap.Consistency.Kafka
             _consumerClient.Assignment.Add(new TopicPartition(topicName, partition));
         }
 
-        public void Subscribe(IEnumerable<KafkaTopicPartition> topicList) {
-
-            if (_consumerClient == null) {
-                InitKafkaClient();
-            }
-
-            if (topicList == null || topicList.Count() == 0) {
-                throw new ArgumentNullException(nameof(topicList));
-            }
-
-            foreach (var item in topicList) {
-                Subscribe(item.Topic, item.Partition);
-            }
-        }
-
-
         public void Listening(TimeSpan timeout) {
             while (true) {
                 _consumerClient.Poll(timeout);
@@ -95,7 +72,5 @@ namespace Cap.Consistency.Kafka
     
         #endregion
 
-        //public void 
-
     }
 }
diff --git a/src/Cap.Consistency.Kafka/KafkaProducerClient.cs b/src/Cap.Consistency.Kafka/KafkaProducerClient.cs
new file mode 100644
index 0000000..671b661
--- /dev/null
+++ b/src/Cap.Consistency.Kafka/KafkaProducerClient.cs
@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Cap.Consistency.Kafka
+{
+    public class KafkaProducerClient
+    {
+
+    }
+}