Running the CustomStreamsProcessor

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

$ gradle build

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

BUILD SUCCESSFUL in 1s
6 actionable task: 6 up-to-date

1. The first step is to run a console consumer for the uptimes topic, shown as follows:

$ ./bin/kafka-console-consumer --bootstrap-server localhost:9092 
--topic uptimes --property print.key=true

2. From our IDE, run the main method of the CustomStreamsProcessor
3. From our IDE, run the main method of the CustomProducer (built in previous chapters)
4. The output on the console consumer for the uptimes topic should be similar to the following:

      EW05-HV36 33
      BO58-SB28 20
      DV03-ZT93 46
      ...