-
Notifications
You must be signed in to change notification settings - Fork 14
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
1 changed file
with
4 additions
and
5 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -6,7 +6,7 @@ Beam is a http based streaming and queueing system that is backed up by Apache P | |
|
||
1. Data can be sent to Pulsar via an HTTP POST method as a producer. | ||
2. To consume the data, data can be pushed to a webhook. | ||
3. To consume the data, data can be retrieved by an HTTP GET method. | ||
3. A webhook can reply processed message, in the response body, back to another Pulsar topic via Pulsar Beam. | ||
|
||
The development is in an early stage. Please email `[email protected]` for any inquiry or demo. Opening an issue and PR are welcomed! | ||
|
||
|
@@ -30,10 +30,9 @@ These HTTP headers are required to map to Pulsar topic. | |
3. PulsarUrl -> a fully qualified pulsar or pulsar+ssl URL is required | ||
|
||
### Webhook registration | ||
Webhook registration is done via REST API backed by MongoDB. | ||
|
||
In the current prototype, webhook registration is specified in ./config/prototype-db/default.json. | ||
|
||
The registration will be moved to a permenant database soon. | ||
TODO: add REST API document. | ||
|
||
### Sink source | ||
|
||
|
@@ -84,4 +83,4 @@ This is an example of file based user Pulsar topic configurations. | |
|
||
``` | ||
$ sudo docker run -d -it -v /etc/pki/ca-trust/extracted/pem/tls-ca-bundle.pem:/etc/ssl/certs/ca-bundle.crt -v /home/ming/go/src/github.com/pulsar-beam/config:/root/config -p 3000:3000 --name=pbeam-server pulsar-beam | ||
``` | ||
``` |