385.5. 示例
您可以保护集群 Camel 应用程序,使其仅使用来自一个活跃节点的文件。
// the file endpoint we want to consume from
String url = "file:target/inbox?delete=true";
// use the zookeeper master component in the clustered group named myGroup
// to run a master/slave mode in the following Camel url
from("zookeeper-master:myGroup:" + url)
.log(name + " - Received file: ${file:name}")
.delay(delay)
.log(name + " - Done file: ${file:name}")
.to("file:target/outbox");
默认情况下,zookeeper 将连接到 localhost:2181,但您可以在组件级别上配置它。
MasterComponent master = new MasterComponent();
master.setZooKeeperUrl("myzookeeper:2181");但是,您也可以使用环境变量配置 ZooKeeper ensemble 的 url。
export ZOOKEEPER_URL = "myzookeeper:2181"