pulsar-beam
pulsar-beam copied to clipboard
kafkaesque-io
Pulsar Beam is a streaming service via HTTP built on Apache Pulsar.
These commits optimize memory allocation to reuse buffer instead of keep allocating and release the memory on every request which push a lot of pressure on GC. This pull request...
The link in README.md is broken, or the repository is private for the Helm chart. https://github.com/kafkaesque-io/pulsar-helm-chart/blob/master/helm-chart-sources/pulsar/templates/beamwh-deployment.yaml
Currently, pulsar-beam does not decompress a HTTP request with header `Content-encoding: gzip` before pushing to Pulsar.
Currently the rate limit is hard coded to 200 which is not proper expectation for everyone. So it is better if the number is configurable or set to zero to...
Hi This is more of a question about Pulsar Beam registering webhooks I have a docker instance of Pulsar Standalone, another instance of Pulsar Admin and a docker instance Pulsar...
The detail is explained by https://github.community/t/make-secrets-available-to-builds-of-forks/16166/20 We need to rewrite the test cases to avoid using secrets
[DO NOT MERGE] This is a temporary fix Support all subjection options in JWT - tenant - tenant-client - tenant-client-hash These variations are introduced by JWT token generation, since the...
This is more of a question. If I have multiple webhook configurations and multiple instances of `pulsar-beam` brokers are running, how does the assignment of topics happens? Or, do all...
The work load of pushing data to webhooks are within a single process. To scale up, we shall be able to have multiple brokers/workers to share the load. The first...
Metadata
Owner
Metadata
Pulsar Beam is a streaming service via HTTP built on Apache Pulsar.