Storm Blueprints: Patterns for Distributed Real-time Computation

Introducing the sample application

The application component is a simple Java class that uses the Simple Logging Facade for Java (SLF4J) (http://www.slf4j.org) to log messages. We will simulate an application that begins by generating warning messages at a relatively slow rate, then switches to a state where it generates warning messages at a much faster rate, and finally returns to the slow state as follows:

• Log a warning message every 5 seconds for 30 seconds (slow state)
• Log a warning message every second for 15 seconds (rapid state)
• Log a warning message every 5 seconds for 30 seconds (slow state)

The goal of the application is to generate a simple pattern that our storm topology can recognize and react to by sending notifications when certain ...