Running the SparkProcessor

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

$ gradle jar

If everything is OK, the output is something similar to 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 as follows:

      $ ./bin/confluent start

2. Run a console consumer for the uptimes topic, shown as follows:

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

3. From our IDE, run the main method of the PlainProducer built in previous chapters
4. The output on the console consumer of the producer should be similar to the following:

{"event":"HEALTH_CHECK","factory":"Lake Anyaport","serialNumber":"EW05-HV36","type":"WIND","status":"STARTING...