From a1db0b2e1aeab20a71fb655e4b8d5c467f8d562c Mon Sep 17 00:00:00 2001
From: yangxiaodong <yangxiaodong1214@126.com>
Date: Wed, 10 May 2017 16:54:51 +0800
Subject: [PATCH] refactor.

---
 .../Consumer/Kafka/RdKafkaClient.cs           | 43 -------------------
 1 file changed, 43 deletions(-)
 delete mode 100644 src/Cap.Consistency/Consumer/Kafka/RdKafkaClient.cs

diff --git a/src/Cap.Consistency/Consumer/Kafka/RdKafkaClient.cs b/src/Cap.Consistency/Consumer/Kafka/RdKafkaClient.cs
deleted file mode 100644
index 68f77f9..0000000
--- a/src/Cap.Consistency/Consumer/Kafka/RdKafkaClient.cs
+++ /dev/null
@@ -1,43 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using Confluent.Kafka;
-using Confluent.Kafka.Serialization;
-
-namespace Cap.Consistency.Consumer.Kafka
-{
-    public class RdKafkaClient
-    {
-
-        private Consumer<string, string> _client;
-
-        public RdKafkaClient() {
-
-        }
-
-        public void Start(TopicRouteContext routeContext )  {
-
-            string brokerList = null;// args[0];
-            var topics = new List<string>();// args.Skip(1).ToList();
-
-            var config = new Dictionary<string, object>
-            {
-                { "group.id", "simple-csharp-consumer" },
-                { "bootstrap.servers", brokerList }
-            };
-
-            using (var consumer = new Consumer<Null, string>(config, null, new StringDeserializer(Encoding.UTF8))) {
-                //consumer.Assign(new List<TopicInfo> { new TopicInfo(topics.First(), 0, 0) });
-
-                while (true) {
-                    Message<Null, string> msg;
-                    if (consumer.Consume(out msg)) {
-                        Console.WriteLine($"Topic: {msg.Topic} Partition: {msg.Partition} Offset: {msg.Offset} {msg.Value}");
-                    }
-                }
-            }
-
-        }
-    }
-}