fixed testcase

Author: agapple

example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java

@@ -31,7 +31,8 @@ public class BaseCanalClientTest {
     protected static final String             SEP                = SystemUtils.LINE_SEPARATOR;
     protected static final String             DATE_FORMAT        = "yyyy-MM-dd HH:mm:ss";
     protected volatile boolean                running            = false;
-    protected Thread.UncaughtExceptionHandler handler            = (t, e) -> logger.error("parse events has an error", e);
+    protected Thread.UncaughtExceptionHandler handler            = (t, e) -> logger.error("parse events has an error",
+                                                                     e);
     protected Thread                          thread             = null;
     protected CanalConnector                  connector;
     protected static String                   context_format     = null;
@@ -148,7 +149,7 @@ protected void printEntry(List<Entry> entrys) {
                             entry.getHeader().getGtid(), String.valueOf(delayTime) });
 
                 if (eventType == EventType.QUERY || rowChage.getIsDdl()) {
-                    logger.info(" sql ----> " + rowChage.getSql() + SEP);
+                    logger.info("ddl : " + rowChage.getIsDdl() + " ,  sql ----> " + rowChage.getSql() + SEP);
                     continue;
                 }
 

example/src/main/java/com/alibaba/otter/canal/example/kafka/AbstractKafkaTest.java

@@ -13,8 +13,8 @@ public abstract class AbstractKafkaTest extends BaseCanalClientTest {
     public static String  topic     = "example";
     public static Integer partition = null;
     public static String  groupId   = "g4";
-    public static String  servers   = "slave1:6667,slave2:6667,slave3:6667";
-    public static String  zkServers = "slave1:2181,slave2:2181,slave3:2181";
+    public static String  servers   = "127.0.0.1:9092";
+    public static String  zkServers = "127.0.0.1:2181";
 
     public void sleep(long time) {
         try {

example/src/main/java/com/alibaba/otter/canal/example/rocketmq/AbstractRocektMQTest.java

@@ -4,12 +4,12 @@
 
 public abstract class AbstractRocektMQTest extends BaseCanalClientTest {
 
-    public static String topic       = "example";
-    public static String groupId     = "group";
-    public static String nameServers = "localhost:9876";
-    public static String accessKey   = "";
-    public static String secretKey   = "";
+    public static String  topic              = "example";
+    public static String  groupId            = "group";
+    public static String  nameServers        = "127.0.0.1:9876";
+    public static String  accessKey          = "";
+    public static String  secretKey          = "";
     public static boolean enableMessageTrace = false;
-    public static String accessChannel = "local";
-    public static String namespace = "";
+    public static String  accessChannel      = "local";
+    public static String  namespace          = "";
 }