Pulsar 提供持久化、非持久化两种主题. 给生产者、消费者提供了一个逻辑上的主题地址
管理主题常用命令
列出 topic
bin/pulsar-admin topics list public/default
查看topic提供服务的URL
bin/pulsar-admin topics lookup persistent://public/default/test
授权
bin/pulsar-admin topics grant-permission --actions produce,consume --role AppHmsAlert persistent://public/default/test
获取权限
bin/pulsar-admin topics permissions persistent://public/default/test
取消权限
bin/pulsar-admin topics revoke-permission --role AppHmsAlert persistent://public/default/test
查看是否取消成功
删除 topic
如果有生产消费者在订阅,需要先卸载topic,然后在执行删除操作才能成功删除
bin/pulsar-admin topics delete persistent://public/default/hello
要不然后报如下错误
卸载完topic就可以正常删除topic了
卸载 topic
bin/pulsar-admin topics unload persistent://public/default/hello
查看topic状态
bin/pulsar-admin topics stats persistent://public/default/test
查看topic内部状态
bin/pulsar-admin topics stats-internal persistent://public/default/test
查看消息详情
bin/pulsar-admin topics peek-messages --count 50 --subscription my-subscription persistent://public/default/test
根据消息ID查看
Batch Message ID: 12:9:0 参数可以根据id去查
扫描二维码关注公众号,回复:
12450349 查看本文章
bin/pulsar-admin topics get-message-by-id persistent://public/default/test -l 12 -e 9
查看最后一条消息Id
bin/pulsar-admin topics last-message-id persistent://public/default/test
根据ledgerId和entryId 查看消息,积压的消息可以到具体的内容
bin/pulsar-admin topics get-message-by-id persistent://public/default/test -l 55 -e 5
获取订阅
bin/pulsar-admin topics subscriptions persistent://public/default/test
取消订阅
bin/pulsar-admin topics unsubscribe --subscription 2 persistent://public/default/test
再检查下2的订阅者已被取消
获取bundle
bin/pulsar-admin topics bundle-range persistent://public/default/test
跳过消息(往最新方向拔)
没有执行跳过消息命令前的消息情况
bin/pulsar-admin topics skip --count 10m --subscription consumer-test persistent://public/default/test
执行过上面跳过消息命令的情况
跳过所有消息(跳到最新位置)
$ bin/pulsar-admin topics clear-backlog --subscription consumer-test persistent://public/default/test
重置cursor(把时间回拔)
没有执行重置消息命令前的消息情况
bin/pulsar-admin topics reset-cursor --subscription consumer-test --time 10m persistent://public/default/test
执行重置消息命令前的消息情况
管理未分区的主题
创建Topic
bin/pulsar-admin topics create persistent://public/default/all
查看topic已创建成功
删除topic
bin/pulsar-admin topics delete persistent://public/default/hello
获取资源列表
bin/pulsar-admin topics list public/default
统计Topic信息
bin/pulsar-admin topics stats persistent://public/default/test --get-precise-backlog
管理分区主题
创建Topic并分配分区
bin/pulsar-admin topics create-partitioned-topic persistent://public/default/payment --partitions 4
查看Topic分区数
bin/pulsar-admin topics get-partitioned-topic-metadata persistent://public/default/payment
更新Topic分区数
bin/pulsar-admin topics update-partitioned-topic persistent://public/default/payment --partitions 8
删除Topic分区数
bin/pulsar-admin topics delete-partitioned-topic persistent://public/default/oreder
查看分区详细信息
bin/pulsar-admin topics partitioned-stats persistent://public/default/payment --per-partition
查看topic详细统计信息
bin/pulsar-admin topics stats-internal persistent://public/default/test