public class CanalConnectors extends Object
构造器和说明 |
---|
CanalConnectors() |
限定符和类型 | 方法和说明 |
---|---|
static CanalConnector |
newClusterConnector(List<? extends SocketAddress> addresses,
String destination,
String username,
String password)
创建带cluster模式的客户端链接,自动完成failover切换
|
static CanalConnector |
newClusterConnector(String zkServers,
String destination,
String username,
String password)
创建带cluster模式的客户端链接,自动完成failover切换,服务器列表自动扫描
|
static CanalConnector |
newSingleConnector(SocketAddress address,
String destination,
String username,
String password)
创建单链接的客户端链接
|
public static CanalConnector newSingleConnector(SocketAddress address, String destination, String username, String password)
address
- username
- password
- public static CanalConnector newClusterConnector(List<? extends SocketAddress> addresses, String destination, String username, String password)
addresses
- username
- password
- public static CanalConnector newClusterConnector(String zkServers, String destination, String username, String password)
username
- password
- Copyright © 2013. All rights reserved.