Package for listen topics in kafka
$ git clone [email protected]:Karma-blockchain/kafka-listener.git
$ yarn
$ ./index.js --topics <topic-one>,<topic-two> --host <host:port>
For default host equal localhost:9092.
For default topics equal test
For send message use push function in REPL-mode:
$ ./index.js
> push(<topic>, <message>, <key>)
If you want set <topic> for default, use:
> topic(<topic>)
> send(<message>, <key>)
> send(<message>) //generate <key> how random uuid