org.apache.pulsar.client.api.PulsarClient to org.apache.pulsar.functions.worker.WorkerService