Skip to main content

Enable parallel processing

In cluster mode, you can specify the parallelism (the number of instances to run) to enable parallel processing for a function.

Example1

Specify the --parallelism flag of the create command when deploying a function.

bin/pulsar-admin functions create \
--parallelism 3 \
# Other function info
tip

For an existing function, you can adjust the parallelism by using the update command.

Example2

Specify the parallelism parameter when deploying a function configuration through YAML.

# function-config.yaml
parallelism: 3
inputs:
- persistent://public/default/input-1
output: persistent://public/default/output-1
# other parameters

For an existing function, you can adjust the parallelism by using the update command as follows.

bin/pulsar-admin functions update \
--function-config-file function-config.yaml