#作者：Unstopabler
文章目錄
- permission
- Schema
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
)
