The Pulsar Provisioner component is responsible for creating topics in a Pulsar cluster when asked to do so by the riff system.
For a given riff stream "foo" existing in namespace "my-ns",
a PUT request will be made to this component at /my-ns/foo.
It will react by creating a persistent topic named public/my-ns/foo
in Pulsar (i.e. using the my-ns Pulsar namespace in the public tenant).
Note that because topics are created on demand in Pulsar, and because
this provisioner does not yet support advanced topic configuration options,
it does not actually create the topic. It merely returns its coordinates.
Upon success, it will return its liiklus coordinates in the following json form:
{
"gateway": "<host>:<port>",
"topic": "<created-topic-name>"
}The provisioner should run with the following environment variables configured:
BROKER: the address of a Pulsar cluster to connect to, in the formpulsar://host:port(Currently unused)GATEWAY: the address of a liiklus gRPC endpoint. Will be used as part of the returned coordinates (see above).