diff --git a/src/com/zdemo/IProducer.java b/src/com/zdemo/IProducer.java
index da4b5d9..082da0a 100644
--- a/src/com/zdemo/IProducer.java
+++ b/src/com/zdemo/IProducer.java
@@ -5,8 +5,5 @@ import java.util.logging.Logger;
 public interface IProducer {
     Logger logger = Logger.getLogger(IProducer.class.getSimpleName());
 
-    @Deprecated
-    <T extends Event> void send(T t);
-
     <V> void publish(String topic, V v);
 }
diff --git a/src/com/zdemo/kafak/KafakConsumer.java b/src/com/zdemo/kafak/KafakConsumer.java
index 1ceca8d..fb975ad 100644
--- a/src/com/zdemo/kafak/KafakConsumer.java
+++ b/src/com/zdemo/kafak/KafakConsumer.java
@@ -35,9 +35,6 @@ public abstract class KafakConsumer extends AbstractConsumer implements IConsume
 
     protected Properties props;
 
-    // 0:none 1:restart -1:stop
-    //private int cmd = -1;
-
     public abstract String getGroupid();
 
     private final LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();
diff --git a/src/com/zdemo/kafak/KafakProducer.java b/src/com/zdemo/kafak/KafakProducer.java
index 97c6f67..770c29d 100644
--- a/src/com/zdemo/kafak/KafakProducer.java
+++ b/src/com/zdemo/kafak/KafakProducer.java
@@ -40,7 +40,7 @@ public class KafakProducer implements IProducer, Service {
         }
     }
 
-    @Deprecated
+    /*@Deprecated
     @Override
     public <T extends Event> void send(T t) {
         String v = JsonConvert.root().convertTo(t.value);
@@ -48,7 +48,7 @@ public class KafakProducer implements IProducer, Service {
             v = v.substring(1, v.length() - 1);
         }
         producer.send(new ProducerRecord(t.topic, v));
-    }
+    }*/
 
     @Override
     public <V> void publish(String topic, V v) {
diff --git a/src/com/zdemo/redis/RedisProducer.java b/src/com/zdemo/redis/RedisProducer.java
index bb8b8d9..04bc7e1 100644
--- a/src/com/zdemo/redis/RedisProducer.java
+++ b/src/com/zdemo/redis/RedisProducer.java
@@ -39,22 +39,6 @@ public class RedisProducer implements IProducer, Service {
         }
     }
 
-    @Deprecated
-    @Override
-    public <T extends Event> void send(T t) {
-        try {
-            String v = JsonConvert.root().convertTo(t.value);
-            if (v.startsWith("\"") && v.endsWith("\"")) {
-                v = v.substring(1, v.length() - 1);
-            }
-            osw.write("PUBLISH " + t.topic + " '" + v + "' \r\n");
-            osw.flush();
-        } catch (IOException e) {
-            logger.log(Level.WARNING, "", e);
-
-        }
-    }
-
     @Override
     public <V> void publish(String topic, V v) {
         try {
diff --git a/src/com/zdemo/zdb/ZHubClient.java b/src/com/zdemo/zdb/ZHubClient.java
index cc32609..abdac9b 100644
--- a/src/com/zdemo/zdb/ZHubClient.java
+++ b/src/com/zdemo/zdb/ZHubClient.java
@@ -138,15 +138,6 @@ public abstract class ZHubClient extends AbstractConsumer implements IConsumer,
         return JsonConvert.root().convertTo(v);
     }
 
-    @Deprecated
-    public void send(Event t) {
-        String v = JsonConvert.root().convertTo(t.value);
-        if (v.startsWith("\"") && v.endsWith("\"")) {
-            v = v.substring(1, v.length() - 1);
-        }
-        send("publish", t.topic, v);
-    }
-
     public boolean initSocket() {
         try {
             client = new Socket();