Skip to main content
Version: 3.3.x

Connector Admin CLI

tip

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 docs.

The pulsar-admin tool helps you manage Pulsar connectors.

sources​

An interface for managing Pulsar IO sources (ingress data into Pulsar).

pulsar-admin sources subcommands

Subcommands are:

  • create
  • update
  • delete
  • get
  • status
  • list
  • stop
  • start
  • restart
  • localrun
  • available-sources
  • reload

create​

Submit a Pulsar IO source connector to run in a Pulsar cluster.

Usage​

pulsar-admin sources create options

Options​

FlagDescription
-a, --archiveThe absolute path to the NAR archive for the source.
It also supports url-path (http/https/file [file protocol assumes that file already exists on worker host]) from which worker can download the package.
--classnameThe source's class name.
--cpuThe CPU (in cores) that needs to be allocated per source instance (applicable only to Docker runtime).
--deserialization-classnameThe SerDe classname for the source.
--destination-topic-nameThe Pulsar topic to which data is sent.
--diskThe disk (in bytes) that needs to be allocated per source instance (applicable only to Docker runtime).
--nameThe source's name.
--namespaceThe source's namespace.
--parallelismThe source's parallelism factor, that is, the number of source instances to run.
--processing-guaranteesThe processing guarantees (also named as delivery semantics) applied to the source. A source connector receives messages from external system and writes messages to a Pulsar topic. The --processing-guarantees is used to ensure the processing guarantees for writing messages to the Pulsar topic.
The available values are ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE.
--ramThe RAM (in bytes) that needs to be allocated per source instance (applicable only to the process and Docker runtimes).
-st, --schema-typeThe schema type.
Either a built-in schema (for example, AVRO and JSON) or custom schema class name to be used to encode messages emitted from source.
--source-configSource config key/values.
--source-config-fileThe absolute path to a YAML config file specifying the source's configuration.
-t, --source-typeThe source's connector provider.
--tenantThe source's tenant.
--producer-configThe custom producer configuration (as a JSON string).

update​

Update a already submitted Pulsar IO source connector.

Usage​

pulsar-admin sources update options

Options​

FlagDescription
-a, --archiveThe absolute path to the NAR archive for the source.
It also supports url-path (http/https/file [file protocol assumes that file already exists on worker host]) from which worker can download the package.
--classnameThe source's class name.
--cpuThe CPU (in cores) that needs to be allocated per source instance (applicable only to Docker runtime).
--deserialization-classnameThe SerDe classname for the source.
--destination-topic-nameThe Pulsar topic to which data is sent.
--diskThe disk (in bytes) that needs to be allocated per source instance (applicable only to Docker runtime).
--nameThe source's name.
--namespaceThe source's namespace.
--parallelismThe source's parallelism factor, that is, the number of source instances to run.
--processing-guaranteesThe processing guarantees (also named as delivery semantics) applied to the source. A source connector receives messages from external system and writes messages to a Pulsar topic. The --processing-guarantees is used to ensure the processing guarantees for writing messages to the Pulsar topic.
The available values are ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE.
--ramThe RAM (in bytes) that needs to be allocated per source instance (applicable only to the process and Docker runtimes).
-st, --schema-typeThe schema type.
Either a built-in schema (for example, AVRO and JSON) or custom schema class name to be used to encode messages emitted from source.
--source-configSource config key/values.
--source-config-fileThe absolute path to a YAML config file specifying the source's configuration.
-t, --source-typeThe source's connector provider. The source-type parameter of the currently built-in connectors is determined by the setting of the name parameter specified in the pulsar-io.yaml file.
--tenantThe source's tenant.
--update-auth-dataWhether or not to update the auth data.
Default value: false.

delete​

Delete a Pulsar IO source connector.

Usage​

pulsar-admin sources delete options

Option​

FlagDescription
--nameThe source's name.
--namespaceThe source's namespace.
--tenantThe source's tenant.

get​

Get the information about a Pulsar IO source connector.

Usage​

pulsar-admin sources get options

Options​

FlagDescription
--nameThe source's name.
--namespaceThe source's namespace.
--tenantThe source's tenant.

status​

Check the current status of a Pulsar Source.

Usage​

pulsar-admin sources status options

Options​

FlagDescription
--instance-idThe source ID.
If instance-id is not provided, Pulsar gets status of all instances.
--nameThe source's name.
--namespaceThe source's namespace.
--tenantThe source's tenant.

list​

List all running Pulsar IO source connectors.

Usage​

pulsar-admin sources list options

Options​

FlagDescription
--namespaceThe source's namespace.
--tenantThe source's tenant.

stop​

Stop a source instance.

Usage​

pulsar-admin sources stop options

Options​

FlagDescription
--instance-idThe source instanceID.
If instance-id is not provided, Pulsar stops all instances.
--nameThe source's name.
--namespaceThe source's namespace.
--tenantThe source's tenant.

start​

Start a source instance.

Usage​

pulsar-admin sources start options

Options​

FlagDescription
--instance-idThe source instanceID.
If instance-id is not provided, Pulsar starts all instances.
--nameThe source's name.
--namespaceThe source's namespace.
--tenantThe source's tenant.

restart​

Restart a source instance.

Usage​

pulsar-admin sources restart options

Options​

FlagDescription
--instance-idThe source instanceID.
If instance-id is not provided, Pulsar restarts all instances.
--nameThe source's name.
--namespaceThe source's namespace.
--tenantThe source's tenant.

localrun​

Run a Pulsar IO source connector locally rather than deploying it to the Pulsar cluster.

Usage​

pulsar-admin sources localrun options

Options​

FlagDescription
-a, --archiveThe absolute path to the NAR archive for the Source.
It also supports url-path (http/https/file [file protocol assumes that file already exists on worker host]) from which worker can download the package.
--broker-service-urlThe URL for the Pulsar broker.
--classnameThe source's class name.
--client-auth-paramsClient authentication parameter.
--client-auth-pluginClient authentication plugin using which function-process can connect to broker.
--cpuThe CPU (in cores) that needs to be allocated per source instance (applicable only to the Docker runtime).
--deserialization-classnameThe SerDe classname for the source.
--destination-topic-nameThe Pulsar topic to which data is sent.
--diskThe disk (in bytes) that needs to be allocated per source instance (applicable only to the Docker runtime).
--hostname-verification-enabledEnable hostname verification.
Default value: false.
--nameThe source's name.
--namespaceThe source's namespace.
--parallelismThe source's parallelism factor, that is, the number of source instances to run).
--processing-guaranteesThe processing guarantees (also named as delivery semantics) applied to the source. A source connector receives messages from external system and writes messages to a Pulsar topic. The --processing-guarantees is used to ensure the processing guarantees for writing messages to the Pulsar topic.
The available values are ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE.
--ramThe RAM (in bytes) that needs to be allocated per source instance (applicable only to the Docker runtime).
-st, --schema-typeThe schema type.
Either a built-in schema (for example, AVRO and JSON) or custom schema class name to be used to encode messages emitted from source.
--source-configSource config key/values.
--source-config-fileThe absolute path to a YAML config file specifying the source's configuration.
--source-typeThe source's connector provider.
--tenantThe source's tenant.
--tls-allow-insecureAllow insecure tls connection.
Default value: false.
--tls-trust-cert-pathThe tls trust cert file path.
--use-tlsUse tls connection.
Default value: false.
--producer-configThe custom producer configuration (as a JSON string).

available-sources​

Get the list of Pulsar IO connector sources supported by Pulsar cluster.

Usage​

pulsar-admin sources available-sources

reload​

Reload the available built-in connectors.

Usage​

pulsar-admin sources reload

sinks​

An interface for managing Pulsar IO sinks (egress data from Pulsar).

pulsar-admin sinks subcommands

Subcommands are:

  • create
  • update
  • delete
  • get
  • status
  • list
  • stop
  • start
  • restart
  • localrun
  • available-sinks
  • reload

create​

Submit a Pulsar IO sink connector to run in a Pulsar cluster.

Usage​

pulsar-admin sinks create options

Options​

FlagDescription
-a, --archiveThe absolute path to the archive file for the sink.
It also supports url-path (http/https/file [file protocol assumes that file already exists on worker host]) from which worker can download the package.
--auto-ackWhether or not the framework will automatically acknowledge messages.
--classnameThe sink's class name.
--cpuThe CPU (in cores) that needs to be allocated per sink instance (applicable only to Docker runtime).
--custom-schema-inputsThe map of input topics to schema types or class names (as a JSON string).
--custom-serde-inputsThe map of input topics to SerDe class names (as a JSON string).
--diskThe disk (in bytes) that needs to be allocated per sink instance (applicable only to Docker runtime).
-i, --inputsThe sink's input topic or topics (multiple topics can be specified as a comma-separated list).
--nameThe sink's name.
--namespaceThe sink's namespace.
--parallelismThe sink's parallelism factor, that is, the number of sink instances to run.
--processing-guaranteesThe processing guarantees (also known as delivery semantics) applied to the sink. The --processing-guarantees implementation in Pulsar also relies on sink implementation.
The available values are ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE.
--ramThe RAM (in bytes) that needs to be allocated per sink instance (applicable only to the process and Docker runtimes).
--retain-orderingSink consumes and sinks messages in order.
--sink-configsink config key/values.
--sink-config-fileThe absolute path to a YAML config file specifying the sink's configuration.
-t, --sink-typeThe sink's connector provider. The sink-type parameter of the currently built-in connectors is determined by the setting of the name parameter specified in the pulsar-io.yaml file.
--subs-namePulsar source subscription name if user wants a specific subscription-name for input-topic consumer.
--tenantThe sink's tenant.
--timeout-msThe message timeout in milliseconds.
--topics-patternThe topic pattern to consume from a list of topics under a namespace that matches the pattern.
--input and --topics-pattern are mutually exclusive.
Add SerDe class name for a pattern in --custom-serde-inputs.

update​

Update a Pulsar IO sink connector.

Usage​

pulsar-admin sinks update options

Options​

FlagDescription
-a, --archiveThe absolute path to the archive file for the sink.
It also supports url-path (http/https/file [file protocol assumes that file already exists on worker host]) from which worker can download the package.
--auto-ackWhether or not the framework will automatically acknowledge messages.
--classnameThe sink's class name.
--cpuThe CPU (in cores) that needs to be allocated per sink instance (applicable only to Docker runtime).
--custom-schema-inputsThe map of input topics to schema types or class names (as a JSON string).
--custom-serde-inputsThe map of input topics to SerDe class names (as a JSON string).
--diskThe disk (in bytes) that needs to be allocated per sink instance (applicable only to Docker runtime).
-i, --inputsThe sink's input topic or topics (multiple topics can be specified as a comma-separated list).
--nameThe sink's name.
--namespaceThe sink's namespace.
--parallelismThe sink's parallelism factor, that is, the number of sink instances to run.
--processing-guaranteesThe processing guarantees (also known as delivery semantics) applied to the sink. The --processing-guarantees implementation in Pulsar also relies on sink implementation.
The available values are ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE.
--ramThe RAM (in bytes) that needs to be allocated per sink instance (applicable only to the process and Docker runtimes).
--retain-orderingSink consumes and sinks messages in order.
--sink-configsink config key/values.
--sink-config-fileThe absolute path to a YAML config file specifying the sink's configuration.
-t, --sink-typeThe sink's connector provider.
--subs-namePulsar source subscription name if user wants a specific subscription-name for input-topic consumer.
--tenantThe sink's tenant.
--timeout-msThe message timeout in milliseconds.
--topics-patternThe topic pattern to consume from a list of topics under a namespace that matches the pattern.
--input and --topics-pattern are mutually exclusive.
Add SerDe class name for a pattern in --custom-serde-inputs.
--update-auth-dataWhether or not to update the auth data.
Default value: false.

delete​

Delete a Pulsar IO sink connector.

Usage​

pulsar-admin sinks delete options

Option​

FlagDescription
--nameThe sink's name.
--namespaceThe sink's namespace.
--tenantThe sink's tenant.

get​

Get the information about a Pulsar IO sink connector.

Usage​

pulsar-admin sinks get options

Options​

FlagDescription
--nameThe sink's name.
--namespaceThe sink's namespace.
--tenantThe sink's tenant.

status​

Check the current status of a Pulsar sink.

Usage​

pulsar-admin sinks status options

Options​

FlagDescription
--instance-idThe sink ID.
If instance-id is not provided, Pulsar gets status of all instances.
--nameThe sink's name.
--namespaceThe sink's namespace.
--tenantThe sink's tenant.

list​

List all running Pulsar IO sink connectors.

Usage​

pulsar-admin sinks list options

Options​

FlagDescription
--namespaceThe sink's namespace.
--tenantThe sink's tenant.

stop​

Stop a sink instance.

Usage​

pulsar-admin sinks stop options

Options​

FlagDescription
--instance-idThe sink instanceID.
If instance-id is not provided, Pulsar stops all instances.
--nameThe sink's name.
--namespaceThe sink's namespace.
--tenantThe sink's tenant.

start​

Start a sink instance.

Usage​

pulsar-admin sinks start options

Options​

FlagDescription
--instance-idThe sink instanceID.
If instance-id is not provided, Pulsar starts all instances.
--nameThe sink's name.
--namespaceThe sink's namespace.
--tenantThe sink's tenant.

restart​

Restart a sink instance.

Usage​

pulsar-admin sinks restart options

Options​

FlagDescription
--instance-idThe sink instanceID.
If instance-id is not provided, Pulsar restarts all instances.
--nameThe sink's name.
--namespaceThe sink's namespace.
--tenantThe sink's tenant.

localrun​

Run a Pulsar IO sink connector locally rather than deploying it to the Pulsar cluster.

Usage​

pulsar-admin sinks localrun options

Options​

FlagDescription
-a, --archiveThe absolute path to the archive file for the sink.
It also supports url-path (http/https/file [file protocol assumes that file already exists on worker host]) from which worker can download the package.
--auto-ackWhether or not the framework will automatically acknowledge messages.
--broker-service-urlThe URL for the Pulsar broker.
--classnameThe sink's class name.
--client-auth-paramsClient authentication parameter.
--client-auth-pluginClient authentication plugin using which function-process can connect to broker.
--cpuThe CPU (in cores) that needs to be allocated per sink instance (applicable only to the Docker runtime).
--custom-schema-inputsThe map of input topics to Schema types or class names (as a JSON string).
--max-redeliver-countMaximum number of times that a message is redelivered before being sent to the dead letter queue.
--dead-letter-topicName of the dead letter topic where the failing messages are sent.
--custom-serde-inputsThe map of input topics to SerDe class names (as a JSON string).
--diskThe disk (in bytes) that needs to be allocated per sink instance (applicable only to the Docker runtime).
--hostname-verification-enabledEnable hostname verification.
Default value: false.
-i, --inputsThe sink's input topic or topics (multiple topics can be specified as a comma-separated list).
--nameThe sink's name.
--namespaceThe sink's namespace.
--parallelismThe sink's parallelism factor, that is, the number of sink instances to run).
--processing-guaranteesThe processing guarantees (also known as delivery semantics) applied to the sink. The --processing-guarantees implementation in Pulsar also relies on sink implementation.
The available values are ATLEAST_ONCE, ATMOST_ONCE, EFFECTIVELY_ONCE.
--ramThe RAM (in bytes) that needs to be allocated per sink instance (applicable only to the Docker runtime).
--retain-orderingSink consumes and sinks messages in order.
--sink-configsink config key/values.
--sink-config-fileThe absolute path to a YAML config file specifying the sink's configuration.
--sink-typeThe sink's connector provider.
--subs-namePulsar source subscription name if user wants a specific subscription-name for input-topic consumer.
--tenantThe sink's tenant.
--timeout-msThe message timeout in milliseconds.
--negative-ack-redelivery-delay-msThe negatively-acknowledged message redelivery delay in milliseconds.
--tls-allow-insecureAllow insecure tls connection.
Default value: false.
--tls-trust-cert-pathThe tls trust cert file path.
--topics-patternThe topic pattern to consume from a list of topics under a namespace that matches the pattern.
--input and --topics-pattern are mutually exclusive.
Add SerDe class name for a pattern in --custom-serde-inputs.
--use-tlsUse tls connection.
Default value: false.

available-sinks​

Get the list of Pulsar IO connector sinks supported by Pulsar cluster.

Usage​

pulsar-admin sinks available-sinks

reload​

Reload the available built-in connectors.

Usage​

pulsar-admin sinks reload