#作者：Unstopabler
文章目录
permission
pulsar的权限控制是在namespace级别的
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin namespaces grant-permission mytenant/mynamespace
–actions produce,consume
–role admin10
注意： 当broker.conf中的authorizationAllowWildcardsMatching 为true时，支持通配符匹配，例如:
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin namespaces grant-permission mytenant/mynamespace
–actions produce,consume
–role ‘my.role.*’
获取授权信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin namespaces permissions mytenant/mynamespace
撤销授权
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin namespaces revoke-permission mytenant/mynamespace
–role admin10
persistent topics
格式： persistent://tenant/namespace/topic
查看namespace下的topic信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent list mytenant/my-namespace
列举persistent topic
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics list tenant/namespace
给客户端添加针对于某个topic的role
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent grant-permission --actions produce,consume --role myapplication
persistent://mytenant/mynamespace/mytopic
获取许可信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent permissions
persistent://mytenant/mynamespace/mytopic
回滚许可
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent revoke-permission
–role myapplication
persistent://mytenant/mynamespace/mytopic \
删除topic
pulsar-admin persistent delete
persistent://mytenant/mynamespace/mytopic \
下线topic
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent unload
persistent://mytenant/mynamespace/mytopic
查看topic相关的统计信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent stats
persistent://mytenant/mynamespace/mytopic
查看topic内部统计信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent stats-internal
persistent://mytenant/mynamespace/mytopic
peek 消息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent peek-messages
–count 10 --subscription my-subscription
persistent://mytenant/mynamespace/mytopic
跳过消费部分消息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent skip
–count 10 --subscription my-subscription
persistent://mytenant/mynamespace/mytopic
跳过所有数据
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent skip-all
–subscription my-subscription
persistent://mytenant/mynamespace/mytopic \
重置消费cursor到几分钟之前
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent reset-cursor
–subscription my-subscription --time 10
persistent://mytenant/mynamespace/mytopic \
查找topic所在的broker信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent lookup
persistent://mytenant/mynamespace/mytopic \
获取topic的bundle信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent bundle-range
persistent://mytenant/mynamespace/mytopic
“0x00000000_0xffffffff”
查询topic的订阅信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent subscriptions
persistent://mytenant/mynamespace/mytopic \
取消订阅
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin persistent unsubscribe
–subscription my-subscription
persistent://mytenant/mynamespace/mytopic \
最后一条消息的MessageID
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics last-message-id topic-name non-persistent topics
格式 ： non-persistent://tenant/namespace/topic
获取统计信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin non-persistent stats
non-persistent://mytenant/mynamespace/mytopic \
获取内存统计信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin non-persistent stats-internal
non-persistent://mytenant/mynamespace/mytopic \
创建分区topic
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin non-persistent create-partitioned-topic
non-persistent://mytenant/my-namespace/mytopic
–partitions 4
注意：需要指明topic名称和分区数量
分区topic的元数据信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin non-persistent get-partitioned-topic-metadata
non-persistent://mytenant/my-namespace/mytopic
下线topic
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin non-persistent unload
non-persistent://mytenant/mynamespace/mytopic
分区topic
格式： persistent://tenant/namespace/topic
创建topic
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics create-partitioned-topic \
persistent://mytenant/my-namespace/mytopic
–partitions 4
创建非分区topic
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics create persistent://mytenant/my-namespace/mytopic
获取分区topic的元数据信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics get-partitioned-topic-metadata
persistent://mytenant/my-namespace/mytopic
更新topic信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics update-partitioned-topic
persistent://mytenant/my-namespace/mytopic
–partitions 8
注意：修改分区数量时，只能比原来的分区数大
删除topic
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics delete-partitioned-topic
persistent://mytenant/my-namespace/mytopic
获取统计信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics partitioned-stats
persistent://mytenant/namespace/topic
–per-partition
获取内部统计信息
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin topics stats-internal
persistent://mytenant/namespace/topic
Schema
上传schema
kubectl exec pulsar-toolset-0 -n pulsar -- bin/pulsar-admin schemas upload <topic-name> --filename /path/to/schema-definition-file
获取schema
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin schemas get mytopic
删除schema
kubectl exec pulsar-toolset-0 -n pulsar – bin/pulsar-admin schemas delete mytopic