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