From f6c4dbec6a7086264d6999fb4666013d12c0165b Mon Sep 17 00:00:00 2001 From: agapple Date: Mon, 28 Oct 2013 23:45:16 -0700 Subject: [PATCH] Updated ClientAPI (markdown) --- ClientAPI.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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,"", "");