chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed testcase

Browse Source
This commit is contained in:
agapple
2021-04-19 15:15:10 +08:00
parent 0c399509a9
commit f9e0dc7daa
3 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java
View File

@@ -31,7 +31,8 @@ public class BaseCanalClientTest {
protected static final String SEP = SystemUtils.LINE_SEPARATOR; protected static final String SEP = SystemUtils.LINE_SEPARATOR;
protected static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss"; protected static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";
protected volatile boolean running = false; 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 Thread thread = null;
protected CanalConnector connector; protected CanalConnector connector;
protected static String context_format = null; protected static String context_format = null;
@@ -148,7 +149,7 @@ public class BaseCanalClientTest {
entry.getHeader().getGtid(), String.valueOf(delayTime) }); entry.getHeader().getGtid(), String.valueOf(delayTime) });
if (eventType == EventType.QUERY || rowChage.getIsDdl()) { if (eventType == EventType.QUERY || rowChage.getIsDdl()) {
logger.info(" sql ----> " + rowChage.getSql() + SEP); logger.info("ddl : " + rowChage.getIsDdl() + " , sql ----> " + rowChage.getSql() + SEP);
continue; continue;
} }

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

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

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

@@ -6,7 +6,7 @@ public abstract class AbstractRocektMQTest extends BaseCanalClientTest {
public static String topic = "example"; public static String topic = "example";
public static String groupId = "group"; public static String groupId = "group";
public static String nameServers = "localhost:9876"; public static String nameServers = "127.0.0.1:9876";
public static String accessKey = ""; public static String accessKey = "";
public static String secretKey = ""; public static String secretKey = "";
public static boolean enableMessageTrace = false; public static boolean enableMessageTrace = false;