Running the log analysis topology
To run the analysis topology, first make sure that ZooKeeper, Kafka, and OpenFire are all up and running by using the procedures outlined earlier in the chapter. Then, run the main() method of the topology.
When the topology activates, the storm XMPP user will connect to the XMPP server and trigger a presence event. If you are logged into the same server with an XMPP client and have the storm user in your buddy list, you will see it become available. This is shown in the following screenshot:
Next, run the RogueApplication class and wait for a minute. You should receive an instant message notification indicating that ...
Get Storm Blueprints: Patterns for Distributed Real-time Computation now with the O’Reilly learning platform.
O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.
