第 385 章 ZooKeeper 组件
从 Camel 版本 2.9 开始提供
ZooKeeper 组件允许与 ZooKeeper 集群交互,并将以下功能公开给 Camel:
- 在任何 ZooKeeper 创建模式中创建节点。
-
获取和设置任意集群节点的数据内容(设置数据必须可转换为
byte[]
)。 - 创建并检索附加到特定节点的子节点的列表。
-
利用 ZooKeeper 协调的领导选举机制的分布式
RoutePolicy
,以确定是否应处理交换。
Maven 用户需要将以下依赖项添加到此组件的 pom.xml
中:
<dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-zookeeper</artifactId> <version>x.x.x</version> <!-- use the same version as your Camel core version --> </dependency>
385.1. URI 格式
zookeeper://zookeeper-server[:port][/path][?options]
URI 的路径指定 ZooKeeper 服务器(a.k.a)中的节点。将作为端点的目标 znode: