diff --git a/src/com/zdemo/IConsumer.java b/src/com/zdemo/IConsumer.java
index 20225f1..1ac291a 100644
--- a/src/com/zdemo/IConsumer.java
+++ b/src/com/zdemo/IConsumer.java
@@ -3,8 +3,10 @@ package com.zdemo;
 import org.redkale.util.TypeToken;
 
 import java.util.Collection;
+import java.util.logging.Logger;
 
 public interface IConsumer<T extends Event> {
+    Logger logger = Logger.getLogger(IConsumer.class.getSimpleName());
 
     Collection<String> getSubscribes();
 
diff --git a/src/com/zdemo/IProducer.java b/src/com/zdemo/IProducer.java
index e088548..a7a6cdc 100644
--- a/src/com/zdemo/IProducer.java
+++ b/src/com/zdemo/IProducer.java
@@ -1,11 +1,12 @@
 package com.zdemo;
 
 import java.util.concurrent.CompletableFuture;
+import java.util.logging.Logger;
 
 public interface IProducer<T extends Event> {
+    Logger logger = Logger.getLogger(IProducer.class.getSimpleName());
 
-
-    default CompletableFuture sendAsync(String topic, T... t) {
+    default CompletableFuture sendAsync(T... t) {
         return CompletableFuture.runAsync(() -> send(t));
     }
 
diff --git a/src/com/zdemo/kafak/KafakConsumer.java b/src/com/zdemo/kafak/KafakConsumer.java
index 52a5a17..b0a2c2c 100644
--- a/src/com/zdemo/kafak/KafakConsumer.java
+++ b/src/com/zdemo/kafak/KafakConsumer.java
@@ -18,7 +18,6 @@ import java.io.IOException;
 import java.time.Duration;
 import java.util.Properties;
 import java.util.concurrent.CompletableFuture;
-import java.util.logging.Logger;
 
 /**
  * 消费
@@ -28,8 +27,6 @@ import java.util.logging.Logger;
 @RestService
 public abstract class KafakConsumer<T extends Event> implements IConsumer<T>, Service {
 
-    private final Logger logger = Logger.getLogger(this.getClass().getSimpleName());
-
     @Resource(name = "APP_HOME")
     protected File APP_HOME;
 
diff --git a/src/com/zdemo/kafak/KafakProducer.java b/src/com/zdemo/kafak/KafakProducer.java
index 7cddefb..6176a52 100644
--- a/src/com/zdemo/kafak/KafakProducer.java
+++ b/src/com/zdemo/kafak/KafakProducer.java
@@ -15,7 +15,6 @@ import java.io.FileInputStream;
 import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.util.Properties;
-import java.util.logging.Logger;
 
 /**
  * 生产
@@ -24,7 +23,6 @@ import java.util.logging.Logger;
  */
 @RestService
 public class KafakProducer<T extends Event> implements IProducer<T>, Service {
-    private final Logger logger = Logger.getLogger(this.getClass().getSimpleName());
     private KafkaProducer<String, String> producer;
 
     @Resource(name = "APP_HOME")
diff --git a/src/com/zdemo/redis/RedisConsumer.java b/src/com/zdemo/redis/RedisConsumer.java
index 65d1792..f70fcc0 100644
--- a/src/com/zdemo/redis/RedisConsumer.java
+++ b/src/com/zdemo/redis/RedisConsumer.java
@@ -60,8 +60,13 @@ public abstract class RedisConsumer<T extends Event> implements IConsumer<T>, Se
 
                     br.readLine(); //$n len(value)
                     String value = br.readLine(); // value
-                    T t = JsonConvert.root().convertFrom(getTypeToken().getType(), value);
-                    accept(t);
+                    try {
+                        T t = JsonConvert.root().convertFrom(getTypeToken().getType(), value);
+                        accept(t);
+                    } catch (Exception e) {
+                        logger.warning("event fmt error :" + value);
+                        e.printStackTrace();
+                    }
                 }
             }
         } catch (Exception e) {