Tests Pulsar with Server Sent Events (SSE) and Command Query
gradle clean shadowJar
docker pull apachepulsar/pulsar
docker run -it -p 6650:6650 -p 8080:8080 -v ~/data:/pulsar/data apachepulsar/pulsar bin/pulsar standalone
http://localhost:8000/poll?topic=test&sname=subN
http://localhost:8000/sub?topic=test&sname=subN
http://localhost:8000/post?topic=test
java -jar build/libs/sse-0.1-all.jar --bootstrap=pulsar://localhost
java -cp build/libs/sse-0.1-all.jar io.streamz.sse.producer.Main -m 'testing' -c 10
java -cp build/libs/sse-0.1-all.jar io.streamz.sse.consumer.Main
java -cp build/libs/sse-0.1-all.jar io.streamz.sse.consumer.Main -f messageId -n subN