This is a Java application for consuming data from Pulsar and forwarding to to Fluentd. From fluentd you can forward to elasticsearch or other outputs.
This was forked from treasure-data/kafka-fluentd-consumer and changed for apache pulsar
Use gradle 2.1 or later.
$ gradle shadowJar
Start pulsar localy or from docker and create topic/s