Pulsar admin CLI
Important
This page is deprecated and not updated anymore. For the latest and complete information about
Pulsar admin
, including commands, flags, descriptions, and more, see Pulsar admin doc
The pulsar-admin
tool enables you to manage Pulsar installations, including clusters, brokers, namespaces, tenants, and more.
Usage
$ pulsar-admin command
Commands
-
broker-stats
-
brokers
-
clusters
-
functions
-
functions-worker
-
namespaces
-
ns-isolation-policy
-
sources
For more information, see here
-
sinks
For more information, see here
-
topics
-
tenants
-
resource-quotas
-
schemas
broker-stats
​
Operations to collect broker statistics
$ pulsar-admin broker-stats subcommand
Subcommands
allocator-stats
topics(destinations)
mbeans
monitoring-metrics
load-report
allocator-stats
​
Dump allocator stats
Usage
$ pulsar-admin broker-stats allocator-stats allocator-name
topics(destinations)
​
Dump topic stats
Usage
$ pulsar-admin broker-stats topics options
Options
Flag | Description | Default |
---|---|---|
-i , --indent | Indent JSON output | false |
mbeans
​
Dump Mbean stats
Usage
$ pulsar-admin broker-stats mbeans options
Options
Flag | Description | Default |
---|---|---|
-i , --indent | Indent JSON output | false |
monitoring-metrics
​
Dump metrics for monitoring
Usage
$ pulsar-admin broker-stats monitoring-metrics options
Options
Flag | Description | Default |
---|---|---|
-i , --indent | Indent JSON output | false |
load-report
​
Dump broker load-report
Usage
$ pulsar-admin broker-stats load-report
brokers
​
Operations about brokers
$ pulsar-admin brokers subcommand
Subcommands
list
namespaces
update-dynamic-config
list-dynamic-config
get-all-dynamic-config
get-internal-config
get-runtime-config
healthcheck
list
​
List active brokers of the cluster
Usage
$ pulsar-admin brokers list cluster-name
leader-broker
​
Get the information of the leader broker
Usage
$ pulsar-admin brokers leader-broker
namespaces
​
List namespaces owned by the broker
Usage
$ pulsar-admin brokers namespaces cluster-name options
Options
Flag | Description | Default |
---|---|---|
--url | The URL for the broker |
update-dynamic-config
​
Update a broker's dynamic service configuration
Usage
$ pulsar-admin brokers update-dynamic-config options
Options
Flag | Description | Default |
---|---|---|
--config | Service configuration parameter name | |
--value | Value for the configuration parameter value specified using the --config flag |
list-dynamic-config
​
Get list of updatable configuration name
Usage
$ pulsar-admin brokers list-dynamic-config
delete-dynamic-config
​
Delete dynamic-serviceConfiguration of broker
Usage
$ pulsar-admin brokers delete-dynamic-config options
Options
Flag | Description | Default |
---|---|---|
--config | Service configuration parameter name |
get-all-dynamic-config
​
Get all overridden dynamic-configuration values
Usage
$ pulsar-admin brokers get-all-dynamic-config
get-internal-config
​
Get internal configuration information
Usage
$ pulsar-admin brokers get-internal-config
get-runtime-config
​
Get runtime configuration values
Usage
$ pulsar-admin brokers get-runtime-config
healthcheck
​
Run a health check against the broker
Usage
$ pulsar-admin brokers healthcheck
clusters
​
Operations about clusters
Usage
$ pulsar-admin clusters subcommand
Subcommands
get
create
update
delete
list
update-peer-clusters
get-peer-clusters
get-failure-domain
create-failure-domain
update-failure-domain
delete-failure-domain
list-failure-domains
get
​
Get the configuration data for the specified cluster
Usage
$ pulsar-admin clusters get cluster-name
create
​
Provisions a new cluster. This operation requires Pulsar super-user privileges.
Usage
$ pulsar-admin clusters create cluster-name options
Options
Flag | Description | Default |
---|---|---|
--broker-url | The URL for the broker service. | |
--broker-url-secure | The broker service URL for a secure connection | |
--url | service-url | |
--url-secure | service-url for secure connection |
update
​
Update the configuration for a cluster
Usage
$ pulsar-admin clusters update cluster-name options
Options
Flag | Description | Default |
---|---|---|
--broker-url | The URL for the broker service. | |
--broker-url-secure | The broker service URL for a secure connection | |
--url | service-url | |
--url-secure | service-url for secure connection |
delete
​
Deletes an existing cluster
Usage
$ pulsar-admin clusters delete cluster-name
list
​
List the existing clusters
Usage
$ pulsar-admin clusters list
update-peer-clusters
​
Update peer cluster names
Usage
$ pulsar-admin clusters update-peer-clusters cluster-name options
Options
Flag | Description | Default |
---|---|---|
--peer-clusters | Comma separated peer cluster names (Pass empty string "" to delete list) |
get-peer-clusters
​
Get list of peer clusters
Usage
$ pulsar-admin clusters get-peer-clusters
get-failure-domain
​
Get the configuration brokers of a failure domain
Usage
$ pulsar-admin clusters get-failure-domain cluster-name options
Options
Flag | Description | Default |
---|---|---|
--domain-name | The failure domain name, which is a logical domain under a Pulsar cluster |
create-failure-domain
​
Create a new failure domain for a cluster (updates it if already created)
Usage
$ pulsar-admin clusters create-failure-domain cluster-name options
Options
Flag | Description | Default |
---|---|---|
--broker-list | Comma separated broker list | |
--domain-name | The failure domain name, which is a logical domain under a Pulsar cluster |
update-failure-domain
​
Update failure domain for a cluster (creates a new one if not exist)
Usage
$ pulsar-admin clusters update-failure-domain cluster-name options
Options
Flag | Description | Default |
---|---|---|
--broker-list | Comma separated broker list | |
--domain-name | The failure domain name, which is a logical domain under a Pulsar cluster |
delete-failure-domain
​
Delete an existing failure domain
Usage
$ pulsar-admin clusters delete-failure-domain cluster-name options
Options
Flag | Description | Default |
---|---|---|
--domain-name | The failure domain name, which is a logical domain under a Pulsar cluster |
list-failure-domains
​
List the existing failure domains for a cluster
Usage
$ pulsar-admin clusters list-failure-domains cluster-name
functions
​
A command-line interface for Pulsar Functions
Usage
$ pulsar-admin functions subcommand
Subcommands
localrun
create
delete
update
get
restart
stop
start
status
stats
list
querystate
putstate
trigger
localrun
​
Run the Pulsar Function locally (rather than deploying it to the Pulsar cluster)
Usage
$ pulsar-admin functions localrun options
Options
Flag | Description | Default |
---|---|---|
--cpu | The cpu in cores that need to be allocated per function instance(applicable only to docker runtime) | |
--ram | The ram in bytes that need to be allocated per function instance(applicable only to process/docker runtime) | |
--disk | The disk in bytes that need to be allocated per function instance(applicable only to docker runtime) | |
--auto-ack | Whether or not the framework will automatically acknowledge messages | |
--subs-name | Pulsar source subscription name if user wants a specific subscription-name for input-topic consumer | |
--broker-service-url | The URL of the Pulsar broker | |
--classname | The function's class name | |
--custom-serde-inputs | The map of input topics to SerDe class names (as a JSON string) | |
--custom-schema-inputs | The map of input topics to Schema class names (as a JSON string) | |
--client-auth-params | Client authentication param | |
--client-auth-plugin | Client authentication plugin using which function-process can connect to broker | |
--function-config-file | The path to a YAML config file specifying the function's configuration | |
--hostname-verification-enabled | Enable hostname verification | false |
--instance-id-offset | Start the instanceIds from this offset | 0 |
--inputs | The function's input topic or topics (multiple topics can be specified as a comma-separated list) | |
--log-topic | The topic to which the function's logs are produced | |
--jar | Path to the jar file for the function (if the function is written in Java). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--name | The function's name | |
--namespace | The function's namespace | |
--output | The function's output topic (If none is specified, no output is written) | |
--output-serde-classname | The SerDe class to be used for messages output by the function | |
--parallelism | The function’s parallelism factor, i.e. the number of instances of the function to run | 1 |
--processing-guarantees | The processing guarantees (aka delivery semantics) applied to the function. Possible Values: [ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE] | ATLEAST_ONCE |
--py | Path to the main Python file/Python Wheel file for the function (if the function is written in Python). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--go | Path to the main Go executable binary for the function (if the function is written in Go). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--schema-type | The builtin schema type or custom schema class name to be used for messages output by the function | |
--sliding-interval-count | The number of messages after which the window slides | |
--sliding-interval-duration-ms | The time duration after which the window slides | |
--state-storage-service-url | The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally. | |
--tenant | The function’s tenant | |
--topics-pattern | The topic pattern to consume from list of topics under a namespace that match the pattern. [--input] and [--topic-pattern] are mutually exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (supported for java fun only) | |
--user-config | User-defined config key/values | |
--window-length-count | The number of messages per window | |
--window-length-duration-ms | The time duration of the window in milliseconds | |
--dead-letter-topic | The topic where all messages which could not be processed successfully are sent | |
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--max-message-retries | How many times should we try to process a message before giving up | |
--retain-ordering | Function consumes and processes messages in order | |
--retain-key-ordering | Function consumes and processes messages in key order | |
--timeout-ms | The message timeout in milliseconds | |
--tls-allow-insecure | Allow insecure tls connection | false |
--tls-trust-cert-path | The tls trust cert file path | |
--use-tls | Use tls connection | false |
--producer-config | The custom producer configuration (as a JSON string) |
create
​
Create a Pulsar Function in cluster mode (i.e. deploy it on a Pulsar cluster)
Usage
$ pulsar-admin functions create options
Options
Flag | Description | Default |
---|---|---|
--cpu | The cpu in cores that need to be allocated per function instance(applicable only to docker runtime) | |
--ram | The ram in bytes that need to be allocated per function instance(applicable only to process/docker runtime) | |
--disk | The disk in bytes that need to be allocated per function instance(applicable only to docker runtime) | |
--auto-ack | Whether or not the framework will automatically acknowledge messages | |
--subs-name | Pulsar source subscription name if user wants a specific subscription-name for input-topic consumer | |
--classname | The function's class name | |
--custom-serde-inputs | The map of input topics to SerDe class names (as a JSON string) | |
--custom-schema-inputs | The map of input topics to Schema class names (as a JSON string) | |
--function-config-file | The path to a YAML config file specifying the function's configuration | |
--inputs | The function's input topic or topics (multiple topics can be specified as a comma-separated list) | |
--log-topic | The topic to which the function's logs are produced | |
--jar | Path to the jar file for the function (if the function is written in Java). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--name | The function's name | |
--namespace | The function’s namespace | |
--output | The function's output topic (If none is specified, no output is written) | |
--output-serde-classname | The SerDe class to be used for messages output by the function | |
--parallelism | The function’s parallelism factor, i.e. the number of instances of the function to run | 1 |
--processing-guarantees | The processing guarantees (aka delivery semantics) applied to the function. Possible Values: [ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE] | ATLEAST_ONCE |
--py | Path to the main Python file/Python Wheel file for the function (if the function is written in Python). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--go | Path to the main Go executable binary for the function (if the function is written in Go). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--schema-type | The builtin schema type or custom schema class name to be used for messages output by the function | |
--sliding-interval-count | The number of messages after which the window slides | |
--sliding-interval-duration-ms | The time duration after which the window slides | |
--tenant | The function’s tenant | |
--topics-pattern | The topic pattern to consume from list of topics under a namespace that match the pattern. [--input] and [--topic-pattern] are mutually exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (supported for java fun only) | |
--user-config | User-defined config key/values | |
--window-length-count | The number of messages per window | |
--window-length-duration-ms | The time duration of the window in milliseconds | |
--dead-letter-topic | The topic where all messages which could not be processed | |
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--max-message-retries | How many times should we try to process a message before giving up | |
--retain-ordering | Function consumes and processes messages in order | |
--retain-key-ordering | Function consumes and processes messages in key order | |
--timeout-ms | The message timeout in milliseconds | |
--producer-config | The custom producer configuration (as a JSON string) |
delete
​
Delete a Pulsar Function that's running on a Pulsar cluster
Usage
$ pulsar-admin functions delete options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant |
update
​
Update a Pulsar Function that's been deployed to a Pulsar cluster
Usage
$ pulsar-admin functions update options
Options
Flag | Description | Default |
---|---|---|
--cpu | The cpu in cores that need to be allocated per function instance(applicable only to docker runtime) | |
--ram | The ram in bytes that need to be allocated per function instance(applicable only to process/docker runtime) | |
--disk | The disk in bytes that need to be allocated per function instance(applicable only to docker runtime) | |
--auto-ack | Whether or not the framework will automatically acknowledge messages | |
--subs-name | Pulsar source subscription name if user wants a specific subscription-name for input-topic consumer | |
--classname | The function's class name | |
--custom-serde-inputs | The map of input topics to SerDe class names (as a JSON string) | |
--custom-schema-inputs | The map of input topics to Schema class names (as a JSON string) | |
--function-config-file | The path to a YAML config file specifying the function's configuration | |
--inputs | The function's input topic or topics (multiple topics can be specified as a comma-separated list) | |
--log-topic | The topic to which the function's logs are produced | |
--jar | Path to the jar file for the function (if the function is written in Java). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--name | The function's name | |
--namespace | The function’s namespace | |
--output | The function's output topic (If none is specified, no output is written) | |
--output-serde-classname | The SerDe class to be used for messages output by the function | |
--parallelism | The function’s parallelism factor, i.e. the number of instances of the function to run | 1 |
--processing-guarantees | The processing guarantees (aka delivery semantics) applied to the function. Possible Values: [ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE] | ATLEAST_ONCE |
--py | Path to the main Python file/Python Wheel file for the function (if the function is written in Python). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--go | Path to the main Go executable binary for the function (if the function is written in Go). It also supports URL path [http/https/file (file protocol assumes that file already exists on worker host)/function (package URL from packages management service)] from which worker can download the package. | |
--schema-type | The builtin schema type or custom schema class name to be used for messages output by the function | |
--sliding-interval-count | The number of messages after which the window slides | |
--sliding-interval-duration-ms | The time duration after which the window slides | |
--tenant | The function’s tenant | |
--topics-pattern | The topic pattern to consume from list of topics under a namespace that match the pattern. [--input] and [--topic-pattern] are mutually exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (supported for java fun only) | |
--user-config | User-defined config key/values | |
--window-length-count | The number of messages per window | |
--window-length-duration-ms | The time duration of the window in milliseconds | |
--dead-letter-topic | The topic where all messages which could not be processed | |
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--max-message-retries | How many times should we try to process a message before giving up | |
--retain-ordering | Function consumes and processes messages in order | |
--retain-key-ordering | Function consumes and processes messages in key order | |
--timeout-ms | The message timeout in milliseconds | |
--producer-config | The custom producer configuration (as a JSON string) |
get
​
Fetch information about a Pulsar Function
Usage
$ pulsar-admin functions get options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant |
restart
​
Restart function instance
Usage
$ pulsar-admin functions restart options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--instance-id | The function instanceId (restart all instances if instance-id is not provided) | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant |
stop
​
Stops function instance
Usage
$ pulsar-admin functions stop options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--instance-id | The function instanceId (stop all instances if instance-id is not provided) | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant |
start
​
Starts a stopped function instance
Usage
$ pulsar-admin functions start options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--instance-id | The function instanceId (start all instances if instance-id is not provided) | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant |
status
​
Check the current status of a Pulsar Function
Usage
$ pulsar-admin functions status options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--instance-id | The function instanceId (Get-status of all instances if instance-id is not provided) | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant |
stats
​
Get the current stats of a Pulsar Function
Usage
$ pulsar-admin functions stats options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--instance-id | The function instanceId (Get-stats of all instances if instance-id is not provided) | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant |
list
​
List all of the Pulsar Functions running under a specific tenant and namespace
Usage
$ pulsar-admin functions list options
Options
Flag | Description | Default |
---|---|---|
--namespace | The function's namespace | |
--tenant | The function's tenant |
querystate
​
Fetch the current state associated with a Pulsar Function running in cluster mode
Usage
$ pulsar-admin functions querystate options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
-k , --key | The key for the state you want to fetch | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant | |
-w , --watch | Watch for changes in the value associated with a key for a Pulsar Function | false |
putstate
​
Put a key/value pair to the state associated with a Pulsar Function
Usage
$ pulsar-admin functions putstate options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the Pulsar Function | |
--name | The name of a Pulsar Function | |
--namespace | The namespace of a Pulsar Function | |
--tenant | The tenant of a Pulsar Function | |
-s , --state | The FunctionState that needs to be put |
trigger
​
Triggers the specified Pulsar Function with a supplied value
Usage
$ pulsar-admin functions trigger options
Options
Flag | Description | Default |
---|---|---|
--fqfn | The Fully Qualified Function Name (FQFN) for the function | |
--name | The function's name | |
--namespace | The function's namespace | |
--tenant | The function's tenant | |
--topic | The specific topic name that the function consumes from that you want to inject the data to | |
--trigger-file | The path to the file that contains the data with which you'd like to trigger the function | |
--trigger-value | The value with which you want to trigger the function |
functions-worker
​
Operations to collect function-worker statistics
$ pulsar-admin functions-worker subcommand
Subcommands
function-stats
get-cluster
get-cluster-leader
get-function-assignments
monitoring-metrics
function-stats
​
Dump all functions stats running on this broker
Usage
$ pulsar-admin functions-worker function-stats
get-cluster
​
Get all workers belonging to this cluster
Usage
$ pulsar-admin functions-worker get-cluster
get-cluster-leader
​
Get the leader of the worker cluster
Usage
$ pulsar-admin functions-worker get-cluster-leader
get-function-assignments
​
Get the assignments of the functions across the worker cluster
Usage
$ pulsar-admin functions-worker get-function-assignments
monitoring-metrics
​
Dump metrics for Monitoring
Usage
$ pulsar-admin functions-worker monitoring-metrics
namespaces
​
Operations for managing namespaces
$ pulsar-admin namespaces subcommand
Subcommands
list
topics
policies
create
delete
set-deduplication
set-auto-topic-creation
remove-auto-topic-creation
set-auto-subscription-creation
remove-auto-subscription-creation
permissions
grant-permission
revoke-permission
grant-subscription-permission
revoke-subscription-permission
set-clusters
get-clusters
get-backlog-quotas
set-backlog-quota
remove-backlog-quota
get-persistence
set-persistence
get-message-ttl
set-message-ttl
remove-message-ttl
get-anti-affinity-group
set-anti-affinity-group
get-anti-affinity-namespaces
delete-anti-affinity-group
get-retention
set-retention
unload
split-bundle
set-dispatch-rate
get-dispatch-rate
set-replicator-dispatch-rate
get-replicator-dispatch-rate
set-subscribe-rate
get-subscribe-rate
set-subscription-dispatch-rate
get-subscription-dispatch-rate
clear-backlog
unsubscribe
set-encryption-required
set-delayed-delivery
get-delayed-delivery
set-subscription-auth-mode
get-max-producers-per-topic
set-max-producers-per-topic
get-max-consumers-per-topic
set-max-consumers-per-topic
get-max-consumers-per-subscription
set-max-consumers-per-subscription
get-max-unacked-messages-per-subscription
set-max-unacked-messages-per-subscription
get-max-unacked-messages-per-consumer
set-max-unacked-messages-per-consumer
get-compaction-threshold
set-compaction-threshold
get-offload-threshold
set-offload-threshold
get-offload-deletion-lag
set-offload-deletion-lag
clear-offload-deletion-lag
get-schema-autoupdate-strategy
set-schema-autoupdate-strategy
set-offload-policies
get-offload-policies
set-max-subscriptions-per-topic
get-max-subscriptions-per-topic
remove-max-subscriptions-per-topic
list
​
Get the namespaces for a tenant
Usage
$ pulsar-admin namespaces list tenant-name
topics
​
Get the list of topics for a namespace
Usage
$ pulsar-admin namespaces topics tenant/namespace
policies
​
Get the configuration policies of a namespace
Usage
$ pulsar-admin namespaces policies tenant/namespace
create
​
Create a new namespace
Usage
$ pulsar-admin namespaces create tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-b , --bundles | The number of bundles to activate | 0 |
-c , --clusters | List of clusters this namespace will be assigned |
delete
​
Deletes a namespace. The namespace needs to be empty
Usage
$ pulsar-admin namespaces delete tenant/namespace
set-deduplication
​
Enable or disable message deduplication on a namespace
Usage
$ pulsar-admin namespaces set-deduplication tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
--enable , -e | Enable message deduplication on the specified namespace | false |
--disable , -d | Disable message deduplication on the specified namespace | false |
set-auto-topic-creation
​
Enable or disable autoTopicCreation for a namespace, overriding broker settings
Usage
$ pulsar-admin namespaces set-auto-topic-creation tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
--enable , -e | Enable allowAutoTopicCreation on namespace | false |
--disable , -d | Disable allowAutoTopicCreation on namespace | false |
--type , -t | Type of topic to be auto-created. Possible values: (partitioned, non-partitioned) | non-partitioned |
--num-partitions , -n | Default number of partitions of topic to be auto-created, applicable to partitioned topics only |
remove-auto-topic-creation
​
Remove override of autoTopicCreation for a namespace
Usage
$ pulsar-admin namespaces remove-auto-topic-creation tenant/namespace
set-auto-subscription-creation
​
Enable autoSubscriptionCreation for a namespace, overriding broker settings
Usage
$ pulsar-admin namespaces set-auto-subscription-creation tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
--enable , -e | Enable allowAutoSubscriptionCreation on namespace | false |
remove-auto-subscription-creation
​
Remove override of autoSubscriptionCreation for a namespace
Usage
$ pulsar-admin namespaces remove-auto-subscription-creation tenant/namespace
permissions
​
Get the permissions on a namespace
Usage
$ pulsar-admin namespaces permissions tenant/namespace
grant-permission
​
Grant permissions on a namespace
Usage
$ pulsar-admin namespaces grant-permission tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
--actions | Actions to be granted (produce or consume ) | |
--role | The client role to which to grant the permissions |
revoke-permission
​
Revoke permissions on a namespace
Usage
$ pulsar-admin namespaces revoke-permission tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
--role | The client role to which to revoke the permissions |
grant-subscription-permission
​
Grant permissions to access subscription admin-api
Usage
$ pulsar-admin namespaces grant-subscription-permission tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
--roles | The client roles to which to grant the permissions (comma separated roles) | |
--subscription | The subscription name for which permission will be granted to roles |
revoke-subscription-permission
​
Revoke permissions to access subscription admin-api
Usage
$ pulsar-admin namespaces revoke-subscription-permission tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
--role | The client role to which to revoke the permissions | |
--subscription | The subscription name for which permission will be revoked to roles |
set-clusters
​
Set replication clusters for a namespace
Usage
$ pulsar-admin namespaces set-clusters tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-c , --clusters | Replication clusters ID list (comma-separated values) |
get-clusters
​
Get replication clusters for a namespace
Usage
$ pulsar-admin namespaces get-clusters tenant/namespace
get-backlog-quotas
​
Get the backlog quota policies for a namespace
Usage
$ pulsar-admin namespaces get-backlog-quotas tenant/namespace
set-backlog-quota
​
Set a backlog quota policy for a namespace
Usage
$ pulsar-admin namespaces set-backlog-quota tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-l , --limit | The backlog size limit (for example 10M or 16G ) | |
-lt , --limitTime | Time limit in second, non-positive number for disabling time limit. (for example 3600 for 1 hour) | |
-p , --policy | The retention policy to enforce when the limit is reached. The valid options are: producer_request_hold , producer_exception or consumer_backlog_eviction | |
-t , --type | Backlog quota type to set. The valid options are: destination_storage , message_age | destination_storage |
Example
$ pulsar-admin namespaces set-backlog-quota my-tenant/my-ns \
--limit 2G \
--policy producer_request_hold
$ pulsar-admin namespaces set-backlog-quota my-tenant/my-ns \
--limitTime 3600 \
--policy producer_request_hold \
--type message_age
remove-backlog-quota
​
Remove a backlog quota policy from a namespace
Flag | Description | Default |
---|---|---|
-t , --type | Backlog quota type to remove. The valid options are: destination_storage , message_age | destination_storage |
Usage
$ pulsar-admin namespaces remove-backlog-quota tenant/namespace
get-persistence
​
Get the persistence policies for a namespace
Usage
$ pulsar-admin namespaces get-persistence tenant/namespace
set-persistence
​
Set the persistence policies for a namespace
Usage
$ pulsar-admin namespaces set-persistence tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-a , --bookkeeper-ack-quorum | The number of acks (guaranteed copies) to wait for each entry | 0 |
-e , --bookkeeper-ensemble | The number of bookies to use for a topic | 0 |
-w , --bookkeeper-write-quorum | How many writes to make of each entry | 0 |
-r , --ml-mark-delete-max-rate | Throttling rate of mark-delete operation (0 means no throttle) |
get-message-ttl
​
Get the message TTL for a namespace
Usage
$ pulsar-admin namespaces get-message-ttl tenant/namespace
set-message-ttl
​
Set the message TTL for a namespace
Usage
$ pulsar-admin namespaces set-message-ttl tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-ttl , --messageTTL | Message TTL in seconds. When the value is set to 0 , TTL is disabled. TTL is disabled by default. | 0 |
remove-message-ttl
​
Remove the message TTL for a namespace.
Usage
$ pulsar-admin namespaces remove-message-ttl tenant/namespace
get-anti-affinity-group
​
Get Anti-affinity group name for a namespace
Usage
$ pulsar-admin namespaces get-anti-affinity-group tenant/namespace
set-anti-affinity-group
​
Set Anti-affinity group name for a namespace
Usage
$ pulsar-admin namespaces set-anti-affinity-group tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-g , --group | Anti-affinity group name |
get-anti-affinity-namespaces
​
Get Anti-affinity namespaces grouped with the given anti-affinity group name
Usage
$ pulsar-admin namespaces get-anti-affinity-namespaces options
Options
Flag | Description | Default |
---|---|---|
-c , --cluster | Cluster name | |
-g , --group | Anti-affinity group name | |
-p , --tenant | Tenant is only used for authorization. Client has to be admin of any of the tenant to access this api |
delete-anti-affinity-group
​
Remove Anti-affinity group name for a namespace
Usage
$ pulsar-admin namespaces delete-anti-affinity-group tenant/namespace
get-retention
​
Get the retention policy that is applied to each topic within the specified namespace
Usage
$ pulsar-admin namespaces get-retention tenant/namespace
set-retention
​
Set the retention policy for each topic within the specified namespace
Usage
$ pulsar-admin namespaces set-retention tenant/namespace
Options
Flag | Description | Default |
---|---|---|
-s , --size | The retention size limits (for example 10M, 16G or 3T) for each topic in the namespace. 0 means no retention and -1 means infinite size retention | |
-t , --time | The retention time in minutes, hours, days, or weeks. Examples: 100m, 13h, 2d, 5w. 0 means no retention and -1 means infinite time retention |
unload
​
Unload a namespace or namespace bundle from the current serving broker.
Usage
$ pulsar-admin namespaces unload tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-b , --bundle | {start-boundary}_{end-boundary} (e.g. 0x00000000_0xffffffff) |
split-bundle
​
Split a namespace-bundle from the current serving broker
Usage
$ pulsar-admin namespaces split-bundle tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-b , --bundle | {start-boundary}_{end-boundary} (e.g. 0x00000000_0xffffffff) | |
-u , --unload | Unload newly split bundles after splitting old bundle | false |
set-dispatch-rate
​
Set message-dispatch-rate for all topics of the namespace
Usage
$ pulsar-admin namespaces set-dispatch-rate tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-bd , --byte-dispatch-rate | The byte dispatch rate (default -1 will be overwrite if not passed) | -1 |
-dt , --dispatch-rate-period | The dispatch rate period in second type (default 1 second will be overwrite if not passed) | 1 |
-md , --msg-dispatch-rate | The message dispatch rate (default -1 will be overwrite if not passed) | -1 |
get-dispatch-rate
​
Get configured message-dispatch-rate for all topics of the namespace (Disabled if value < 0)
Usage
$ pulsar-admin namespaces get-dispatch-rate tenant/namespace
set-replicator-dispatch-rate
​
Set replicator message-dispatch-rate for all topics of the namespace
Usage
$ pulsar-admin namespaces set-replicator-dispatch-rate tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-bd , --byte-dispatch-rate | The byte dispatch rate (default -1 will be overwrite if not passed) | -1 |
-dt , --dispatch-rate-period | The dispatch rate period in second type (default 1 second will be overwrite if not passed) | 1 |
-md , --msg-dispatch-rate | The message dispatch rate (default -1 will be overwrite if not passed) | -1 |
get-replicator-dispatch-rate
​
Get replicator configured message-dispatch-rate for all topics of the namespace (Disabled if value < 0)
Usage
$ pulsar-admin namespaces get-replicator-dispatch-rate tenant/namespace
set-subscribe-rate
​
Set subscribe-rate per consumer for all topics of the namespace
Usage
$ pulsar-admin namespaces set-subscribe-rate tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-sr , --subscribe-rate | The subscribe rate (default -1 will be overwrite if not passed) | -1 |
-st , --subscribe-rate-period | The subscribe rate period in second type (default 30 second will be overwrite if not passed) | 30 |
get-subscribe-rate
​
Get configured subscribe-rate per consumer for all topics of the namespace
Usage
$ pulsar-admin namespaces get-subscribe-rate tenant/namespace
set-subscription-dispatch-rate
​
Set subscription message-dispatch-rate for all subscription of the namespace
Usage
$ pulsar-admin namespaces set-subscription-dispatch-rate tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-bd , --byte-dispatch-rate | The byte dispatch rate (default -1 will be overwrite if not passed) | -1 |
-dt , --dispatch-rate-period | The dispatch rate period in second type (default 1 second will be overwrite if not passed) | 1 |
-md , --sub-msg-dispatch-rate | The message dispatch rate (default -1 will be overwrite if not passed) | -1 |
get-subscription-dispatch-rate
​
Get subscription configured message-dispatch-rate for all topics of the namespace (Disabled if value < 0)
Usage
$ pulsar-admin namespaces get-subscription-dispatch-rate tenant/namespace
clear-backlog
​
Clear the backlog for a namespace
Usage
$ pulsar-admin namespaces clear-backlog tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-b , --bundle | {start-boundary}_{end-boundary} (e.g. 0x00000000_0xffffffff) | |
-force , --force | Whether to force a clear backlog without prompt | false |
-s , --sub | The subscription name |
unsubscribe
​
Unsubscribe the given subscription on all destinations on a namespace
Usage
$ pulsar-admin namespaces unsubscribe tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-b , --bundle | {start-boundary}_{end-boundary} (e.g. 0x00000000_0xffffffff) | |
-s , --sub | The subscription name |
set-encryption-required
​
Enable or disable message encryption required for a namespace
Usage
$ pulsar-admin namespaces set-encryption-required tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-d , --disable | Disable message encryption required | false |
-e , --enable | Enable message encryption required | false |
set-delayed-delivery
​
Set the delayed delivery policy on a namespace
Usage
$ pulsar-admin namespaces set-delayed-delivery tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-d , --disable | Disable delayed delivery messages | false |
-e , --enable | Enable delayed delivery messages | false |
-t , --time | The tick time for when retrying on delayed delivery messages | 1s |
get-delayed-delivery
​
Get the delayed delivery policy on a namespace
Usage
$ pulsar-admin namespaces get-delayed-delivery-time tenant/namespace
Options
Flag | Description | Default |
---|---|---|
-t , --time | The tick time for when retrying on delayed delivery messages | 1s |
set-subscription-auth-mode
​
Set subscription auth mode on a namespace
Usage
$ pulsar-admin namespaces set-subscription-auth-mode tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-m , --subscription-auth-mode | Subscription authorization mode for Pulsar policies. Valid options are: [None, Prefix] |
get-max-producers-per-topic
​
Get maxProducersPerTopic for a namespace
Usage
$ pulsar-admin namespaces get-max-producers-per-topic tenant/namespace
set-max-producers-per-topic
​
Set maxProducersPerTopic for a namespace
Usage
$ pulsar-admin namespaces set-max-producers-per-topic tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-p , --max-producers-per-topic | maxProducersPerTopic for a namespace | 0 |
get-max-consumers-per-topic
​
Get maxConsumersPerTopic for a namespace
Usage
$ pulsar-admin namespaces get-max-consumers-per-topic tenant/namespace
set-max-consumers-per-topic
​
Set maxConsumersPerTopic for a namespace
Usage
$ pulsar-admin namespaces set-max-consumers-per-topic tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-c , --max-consumers-per-topic | maxConsumersPerTopic for a namespace | 0 |
get-max-consumers-per-subscription
​
Get maxConsumersPerSubscription for a namespace
Usage
$ pulsar-admin namespaces get-max-consumers-per-subscription tenant/namespace
set-max-consumers-per-subscription
​
Set maxConsumersPerSubscription for a namespace
Usage
$ pulsar-admin namespaces set-max-consumers-per-subscription tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-c , --max-consumers-per-subscription | maxConsumersPerSubscription for a namespace | 0 |
get-max-unacked-messages-per-subscription
​
Get maxUnackedMessagesPerSubscription for a namespace
Usage
$ pulsar-admin namespaces get-max-unacked-messages-per-subscription tenant/namespace
set-max-unacked-messages-per-subscription
​
Set maxUnackedMessagesPerSubscription for a namespace
Usage
$ pulsar-admin namespaces set-max-unacked-messages-per-subscription tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-c , --max-unacked-messages-per-subscription | maxUnackedMessagesPerSubscription for a namespace | -1 |
get-max-unacked-messages-per-consumer
​
Get maxUnackedMessagesPerConsumer for a namespace
Usage
$ pulsar-admin namespaces get-max-unacked-messages-per-consumer tenant/namespace
set-max-unacked-messages-per-consumer
​
Set maxUnackedMessagesPerConsumer for a namespace
Usage
$ pulsar-admin namespaces set-max-unacked-messages-per-consumer tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-c , --max-unacked-messages-per-consumer | maxUnackedMessagesPerConsumer for a namespace | -1 |
get-compaction-threshold
​
Get compactionThreshold for a namespace
Usage
$ pulsar-admin namespaces get-compaction-threshold tenant/namespace
set-compaction-threshold
​
Set compactionThreshold for a namespace
Usage
$ pulsar-admin namespaces set-compaction-threshold tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-t , --threshold | Maximum number of bytes in a topic backlog before compaction is triggered (eg: 10M, 16G, 3T). 0 disables automatic compaction | 0 |
get-offload-threshold
​
Get offloadThreshold for a namespace
Usage
$ pulsar-admin namespaces get-offload-threshold tenant/namespace
set-offload-threshold
​
Set offloadThreshold for a namespace
Usage
$ pulsar-admin namespaces set-offload-threshold tenant/namespace options
Options
Flag | Description | Default |
---|---|---|
-s , --size | Maximum number of bytes stored in the pulsar cluster for a topic before data will start being automatically offloaded to longterm storage (eg: 10M, 16G, 3T, 100). Negative values disable automatic offload. 0 triggers offloading as soon as possible. | -1 |