Creating the log spout
The log topology will read all logs through the Redis channel that is fed by logstash; these logs will be emitted into the topology through the spout described in this recipe. As this is a new topology, we must first create the new topology project.
How to do it…
Start by creating the project directory and the standard Maven folder structure (http://maven.apache.org/guides/introduction/introduction-to-the-standard-directory-layout.html).
- Create the POM as per the Creating a "Hello World" topology recipe in Chapter 1, Setting Up Your Development Environment, updating the
<name>tag values and including the following dependencies:
<dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.11</version> ...