第 385 章 ZooKeeper Component
从 Camel 版本 2.9 开始提供
ZooKeeper 组件允许与 ZooKeeper 集群交互,并在 Camel 中公开以下功能:
- 在任何 ZooKeeper 创建模式中创建节点。
-
获取并设置任意集群节点的数据内容(正在设置的数据必须转换为
byte[]
)。 - 创建并检索附加到特定节点的子节点。
-
一个分布式
RoutePolicy
,它利用 ZooKeeper 协调的领导选举机制来确定是否应处理交换。
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):