First release
First release of Pulsar Beam supports these features:
- An Http endpoint to ingest events sent to Pulsar as producer
- Push based webhook integration allows events to be pushed to any webhook destination
- Webhook integration including Cloud Functions as well. GCP Cloud Function is integrated in CI end to end test. Azure Function has been verified in the work flow.
- A REST API allows Pulsar topic, its credential, and webhook registration and removal. Pulsar compliant token is supported for authentication and authorization.
- Docker builds
Docker image is at
https://hub.docker.com/repository/docker/kafkaesqueio/pulsar-beam