基于k8s环境下的pulsar常用命令（下）

#作者：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