更新时间:2024-05-20 GMT+08:00

开始使用

  • 有关Pulsar详细使用指导请参考Pulsar产品文档
  • 该解决方案默认使用的Pulsar版本:3.1.0,部署的Java版本:JDK-21,部署的Pulsar Manager 版本:0.4.0
  • 已在Pulsar内默认创建了名为pulsar-cluster的集群名
  • 该解决方案涉及的所有的业务端口均默认配置了同一子网可访问,如果另有需要,需根据实际情况修改安全组规则
  • 涉及到的Pulsar业务端口如下:
    • 9527:Pulsar Manager节点的业务面端口
    • 2181,2888,3888: Pulsar Zookeeper节点的业务面端口
    • 8000,3181,4181:Pulsar Bookie节点的业务面端口
    • 6650,6651,8080,8443:Pulsar Broker节点的业务面端口
  • 后续文档将展开Pulsar的基础使用说明

安全组规则修改(可选)

安全组实际是网络流量访问策略,包括网络流量入方向规则和出方向规则,通过这些规则为安全组内具有相同保护需求并且相互信任的云服务器、云容器、云数据库等实例提供安全保护。

如果您的实例关联的安全组策略无法满足使用需求,比如需要添加、修改、删除某个TCP端口,请参考以下内容进行修改。

  • 添加安全组规则:根据业务使用需求需要开放某个TCP端口,请参考添加安全组规则添加入方向规则,打开指定的TCP端口。
  • 修改安全组规则:安全组规则设置不当会造成严重的安全隐患。您可以参考修改安全组规则,来修改安全组中不合理的规则,保证云服务器等实例的网络安全。
  • 删除安全组规则:当安全组规则入方向、出方向源地址/目的地址有变化时,或者不需要开放某个端口时,您可以参考删除安全组规则进行安全组规则删除。

基础使用

  1. 登录华为云弹性云服务器控制台,查看ECS是否正常创建,并查看Manager节点的公网IP地址。

    图1 查看ECS资源以及Pulsar Manager节点的公网,记为“manager-ip

  2. 登录Pulsar Manager Web界面

    ECS创建完成后,后台会进行环境部署,等待约20分钟后,将会完成Pulsar集群的构建,可以登录“http://manager-ip:9527”进入控制台Console界面

    • 在登录前,需保证Pulsar Manager节点机器对登录客户端已开放9527端口,如果未开放,请参考如何修改安全组规则
    • 已默认将admin配置为pulsar集群的管理用户,并开启了jwt token校验
    • 登录的账号名和密码均为默认配置
      • 默认账号名:admin
      • 默认密码:创建ECS服务器时输入的密码
    图2 Pulsar Manager登录界面

  3. 确认Pulsar集群部署完成(可选)

    图3 登录任一Zookeeper节点,连接至Zookeeper服务端

    图4 查看存活的Zookeeper节点,是否与已存在的Zookeeper节点一致

    图5 查看存活的Bookie节点,是否与已存在的Bookie节点一致

    图6 查看存活的Broker节点,是否与已存在的Broker节点一致

  4. 在Pulsar Manager中添加Pulsar环境

    图7 添加Pulsar环境,可选择配置任一brokerbookie节点

  5. 查看Pulsar详情

    图8 查看Pulsar详情,pulsar-cluster是已经内置的Pulsar集群名称

  6. 添加新租户

    图9 添加新租户

  7. 创建命令空间

    图10 创建命名空间

  8. 添加topic

    图11 添加topic

  9. 生成token

    图12 生成token

    至此Pulsar集群已部署完成,您可以在您的应用中集成Pulsar应用了。