pulsar

Apache Pulsar 消息系统 CLI

补充说明

pulsar CLI 管理 Pulsar 的租户、命名空间、主题和订阅，也可以生产和消费消息。Pulsar 的层级是 tenant → namespace → topic。

常用示例

pulsar-admin tenants create app
pulsar-admin namespaces create app/prod
pulsar-admin topics create persistent://app/prod/events
pulsar-admin topics list app/prod
pulsar-admin topics stats persistent://app/prod/events
pulsar-admin namespaces set-retention app/prod --size 10G --time 7d
pulsar-client produce persistent://app/prod/events -m 'hello'
pulsar-client consume persistent://app/prod/events -s worker -n 10

易错点与排错

• 主题全名包含 persistent://tenant/namespace/topic；简写在不同命令里支持程度不同。
• 租户和命名空间要先创建；直接建主题会失败。
• retention 和 backlog 是两套配置；消息积压不等于保留策略生效。
• 订阅类型（Exclusive/Failover/Shared/Key_Shared）决定并发消费行为。
• 生产环境依赖 BookKeeper 和 ZooKeeper/etcd；存储异常会导致写入失败。
• 认证和授权按租户/命名空间配置；权限错误常表现为连接或管理命令被拒。
• 多租户场景注意配额和限流，避免一个租户拖垮集群。

相关命令

• pulsar-admin — 管理命令
• pulsar-client — 生产消费
• nats / kafka-topics — 其他消息系统