Chapter 15. Queuing and stream processing: Illustration
This chapter covers
- Using Apache Storm
- Guaranteeing message processing
- Integrating Apache Kafka, Apache Storm, and Apache Cassandra
- Implementing the SuperWebAnalytics.com uniques-over-time speed layer
In the last chapter you learned about multi-consumer queues and the Storm model as a general approach to one-at-a-time stream processing. Let’s now look at how you can apply these ideas in practice using the real-world tools Apache Storm and Apache Kafka. We’ll conclude the chapter by implementing the speed layer for unique pageviews for SuperWebAnalytics.com.
15.1. Defining topologies with Apache Storm
Apache Storm is an open source project that implements (and originates) the Storm ...