Deploy a function in cluster mode

Deploying a function in cluster mode uploads the function to a function worker, which means the function is scheduled by the worker.

To deploy a function in cluster mode, use the create command.

bin/pulsar-admin functions create \
  --py myfunc.py \
  --classname myfunc.SomeFunction \
  --inputs persistent://public/default/input-1 \
  --output persistent://public/default/output-1

To update a function running in cluster mode, you can use the update command.

bin/pulsar-admin functions update \
  --py myfunc.py \
  --classname myfunc.SomeFunction \
  --inputs persistent://public/default/new-input-topic \
  --output persistent://public/default/new-output-topic

More options

• Allocate resources to function instances
• Enable parallel processing
• Enable end-to-end encryption
• Enable package management service
• Use built-in functions