oven-baked commented on issue #68:
URL: https://github.com/apache/pulsar-dotpulsar/issues/68#issuecomment-777360419
Of course! We've been using this really simple function as supplied in the
Pulsar documentation.
```
from pulsar import Function
class ExclamationFunction(Function):
def __init__(self):
pass
def process(self, input, context):
return input + '!'
```
And then installing it via:
`./pulsar-admin functions create --tenant public --namespace default --name
MyFunction --py /home/oven-baked/apache-pulsar-2.7.0/bin/myfunction.py
--classname myfunction.ExclamationFunction --inputs
persistent://public/default/functioninputtopic --output
persistent://public/default/myconsumertopic`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
