Skip to main content

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 \
--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 \
--classname myfunc.SomeFunction \
--inputs persistent://public/default/new-input-topic \
--output persistent://public/default/new-output-topic

More options