Running the Streams processor

To run the EventProcessor, follow these steps:

1. Create the aggregates topic as follows:

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

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

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

3. From the IDE, run the main method of the EventProducer.
4. From the IDE, run the main method of the EventProcessor.
5. Remember that it writes to the topic every 30 seconds. The output on the console consumer for the aggregates topic should be similar to the following:

1532529050000 10
1532529060000 10
1532529070000 9
1532529080000 3

After the second window, we can see that the values in the KTable are updated with fresh (and correct) data, shown as follows:

1532529050000 10
1532529060000...