说明
Apache Pulsar 是 Apache 软件基金会顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体。该系统源于 Yahoo,最初在 Yahoo 内部开发和部署,支持 Yahoo 应用服务平台 140 万个主题,日处理超过 1000 亿条消息。Pulsar 于 2016 年由 Yahoo 开源并捐赠给 Apache 软件基金会进行孵化,2018 年成为 Apache 软件基金会顶级项目。
Pulsar 作为下一代云原生分布式消息流平台,支持多租户、持久化存储、多机房跨区域数据复制,具有强一致性、高吞吐以及低延时的高可扩展流数据存储特性,内置诸多其他系统商业版本才有的特性,是云原生时代解决实时消息流数据传输、存储和计算的最佳解决方案。 Apache Pulsar 提供了统一的消费模型,支持 Stream(如 Kafka)和 Queue(如 RabbitMQ)两种消费模型, 支持 exclusive、failover 和 shared 三种消费模式。同时,Pulsar 提供和 Kafka 兼容的 API,以及 Kafka-On-Pulsar(KoP) 组件来兼容 Kafka 的应用程序,KoP 在 Pulsar Broker 中解析 Kafka 协议,用户不用改动客户端的任何 Kafka 代码就能直接使用 Pulsar。 目前,Apache Pulsar 已经应用部署在国内外众多大型互联网公司和传统行业公司,案例分布在人工智能、金融、电信运营商、直播与短视频、物联网、零售与电子商务、在线教育等多个行业,如美国有线电视网络巨头 Comcast、Yahoo!、腾讯、中国电信、中国移动、BIGO、VIPKID 等。 目前 Apache Pulsar 项目原生核心贡献者已组成创业公司 StreamNative,进一步为 Apache Pulsar 提供更好的企业级服务支持与生态建设。端口映射
序号 | 服务 | docker 端口映射 | 备注 |
1 | standalone | 8082:8080 | |
2 | 6650:6650 | ||
3 | dashboard | 81:80 | |
4 | pulsar-manager | 9527:9527 | |
7750:7750 |
部署
部署目录统一放在: /data/middleware/内网部署
# 详细配置与镜像已修改
git clone https://git.insightone.cn/middleware/pulsar.git cd pulsar
# 启动
docker-compose up -d
离线部署
下载全部镜像 https://adlereden.cn/middleware/pulsar/images/#导入镜像 sh load_image.sh下载项目 https://adlereden.cn/middleware/pulsar/project/
# 解压项目并启动 unzip pulsar.zip cd pulsar # 启动 docker-compose up -d等待运行完成... 查看启动端口
manager创建账号密码
# 创建token CSRF_TOKEN=$(curl http://localhost:7750/pulsar-manager/csrf-token) # 创建账号 curl -H 'X-XSRF-TOKEN: $CSRF_TOKEN' \创建成功 {"message":"Add super user success, please login"} manager页面添加环境 Service_URL=http://standalone:8080 访问 http://xxxxx:9527 url处填写 http://xxxxx:8080 即可 提示: 填写容器ip+端口 http://172.18.0.13:8080 或 http://standalone:8080 标签:http,Kafka,manager,消息,pulsar,Apache,Pulsar,分布式 From: https://www.cnblogs.com/edeny/p/17101181.html
-H 'Cookie: XSRF-TOKEN=$CSRF_TOKEN;' \
-H "Content-Type: application/json" -X PUT http://localhost:7750/pulsar-manager/users/superuser \
-d '{"name": "admin", "password": "pulsar", "description": "dev", "email": "jianyang@dongjian.com"}'