Running the PlainProducer

To build the project, run this command from the kioto directory:

$ gradle jar

If everything is okay, the output is something like the following:

BUILD SUCCESSFUL in 3s
1 actionable task: 1 executed

1. From a command-line terminal, move to the confluent directory and start it by typing the following:

$ ./bin/confluent start

2. The broker is running on port 9092. To create the healthchecks topic, execute the following:

$ ./bin/kafka-topics --zookeeper localhost:2181 --create --topic             
healthchecks --replication-factor 1 --partitions 4

3. Run a console consumer for the healthchecks topic by typing the following:

$ ./bin/kafka-console-consumer --bootstrap-server localhost:9092       
--topic healthchecks

4. From our IDE, run the main method of the PlainProducer
5. The output on the console consumer should be similar to the following:

{"event":...