Skip to content

Releases: kafkaesque-io/pulsar-beam

HTTP SSE and long polling

31 Aug 15:00
@zzzming zzzming
1.0.0
d9b4b6a
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.
Compare
Choose a tag to compare
HTTP SSE and long polling Latest
Latest

Support HTTP SSE and long polling subscription to consume messages.

Docker image is published at kesque/pulsar-beam:1.0.0

Assets 3
Loading

First release

07 Jan 15:09
@zzzming zzzming
v0.0.1
6a52777
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.
Compare
Choose a tag to compare
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

Assets 2
Loading