kafka
kafka 是一个基于发布-订阅模型的消息系统,其中zookeeper用于检测崩溃,实现主题的发现,并且保持主题的生产和消费状态
api概述
1 | 2 |
---|---|
create/path data | 创建一个名为/path的znode节点 ,并且包含数据data |
delete/path | 删除一个名为/path的znode |
exist/path | 查看是否存在/path节点 |
setData/path data | 设置名为/path的znode,数据为data |
getData/path | 返回名为/path的znode的数据 |
getChildren/path | 返回/path节点下的所有节点列表 |
节点类型
1 | 2 |
---|---|
持久节点 | 一直存在,就是创建者没了他也有 |
临时节点 | 随着回话消失,client主动删除,不允许临时节点有子节点 |
有序节点 |