Running the AvroStreamsProcessor

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 AvroStreamsProcessor
3. From our IDE, run the main method of the AvroProducer (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
       ...