删除：producer 的 send 方法

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<>();

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) {