diff --git a/ClientAPI.md b/ClientAPI.md index c0ba6c7..fce1325 100644 --- a/ClientAPI.md +++ b/ClientAPI.md @@ -98,12 +98,12 @@ Column

1. 创建Connector

-

1. 创建SimpleCanalConnector (直连ip,不支持server/client的failover机制)

+

a. 创建SimpleCanalConnector (直连ip,不支持server/client的failover机制)

CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress(AddressUtils.getHostIp(),11111), destination, "", "");
-
2. 创建ClusterCanalConnector (基于zookeeper获取canal server ip,支持server/client的failover机制) +
b. 创建ClusterCanalConnector (基于zookeeper获取canal server ip,支持server/client的failover机制)
CanalConnector connector = CanalConnectors.newClusterConnector("10.20.144.51:2181", destination, "", "");
-3. 创建ClusterCanalConnector (基于固定canal server的地址,支持固定的server ip的failover机制,不支持client的failover机制
+c. 创建ClusterCanalConnector (基于固定canal server的地址,支持固定的server ip的failover机制,不支持client的failover机制
CanalConnector connector = CanalConnectors.newClusterConnector(Arrays.asList(new InetSocketAddress(AddressUtils.getHostIp(),11111)), destination,"", "");