Awesome

JSON Event Sourcing Console Consumer and Producer

This command-line tool can consume JSON messages, serialized with the JES serializer, from a Kafka topic. It writes one message per line to the console. It can also produce messages on a Kafka topic using the JES serializer. The input from the console can be one JSON object or an array of JSON objects. The field _id is used for the message key.

You can build it with mvn clean package.

Run it as follows:

> java -jar target/pincette-jes-prodcon-<version>-jar-with-dependencies.jar
  (consume | produce)
  (-c | --config-file) $HOME/.ccloud/config
  (-t | --topic) topic

It reads from stdin when producing and writes to stdout when consuming. The format of the configuration file is the same as for your ccloud configuration.