This example shows how to work with the Camel-Pulsar Component.
The example consumes messages from a topic and invoke the bean with the received message.
You can run the Pulsar cluster through docker:
$ docker run --rm -it \ -p 6650:6650 \ -p 8080:8080 \ -v $PWD/target/data:/pulsar/data \ apachepulsar/pulsar \ bin/pulsar standalone
The Server is required to be running when you try the client.
And for the Client we use the ProducerTemplate ala Spring Template style.
The example should run if you type:
If you hit any problem using Camel or have some feedback, then please let us know.
We also love contributors, so get involved :-)
The Camel riders!