Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ```go
- import (
- "fmt"
- "context"
- "github.com/apache/pulsar/pulsar-function-go/pf"
- )
- func HandleRequest(ctx context.Context, in []byte) error {
- fmt.Println(string(in) + "!")
- return nil
- }
- func main() {
- pf.Start(HandleRequest)
- }
- ```
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement