From f9e0dc7daa4f3b4ff6a8f8ab51620ce8b7f427b3 Mon Sep 17 00:00:00 2001 From: agapple Date: Mon, 19 Apr 2021 15:15:10 +0800 Subject: [PATCH] fixed testcase --- .../otter/canal/example/BaseCanalClientTest.java | 5 +++-- .../canal/example/kafka/AbstractKafkaTest.java | 4 ++-- .../example/rocketmq/AbstractRocektMQTest.java | 14 +++++++------- 3 files changed, 12 insertions(+), 11 deletions(-) diff --git a/example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java b/example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java index 235b3b84..e245fa19 100644 --- a/example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java +++ b/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 @@ public class BaseCanalClientTest { 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; } diff --git a/example/src/main/java/com/alibaba/otter/canal/example/kafka/AbstractKafkaTest.java b/example/src/main/java/com/alibaba/otter/canal/example/kafka/AbstractKafkaTest.java index b73db92e..1c177ab3 100644 --- a/example/src/main/java/com/alibaba/otter/canal/example/kafka/AbstractKafkaTest.java +++ b/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 { diff --git a/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/AbstractRocektMQTest.java b/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/AbstractRocektMQTest.java index f9952e61..ea9ae3f6 100644 --- a/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/AbstractRocektMQTest.java +++ b/example/src/main/java/com/alibaba/otter/canal/example/rocketmq/AbstractRocektMQTest.java @@ -4,12 +4,12 @@ import com.alibaba.otter.canal.example.BaseCanalClientTest; 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 = ""; } -- GitLab