We have implemented a Trident topology. A Kafka spout absorbs incoming tweets and does a comparison the tweet data with a USGS Earthquake data stream and returns the probability that a certain tweet is about an earthquake with a magnitude greater than 2.5 on the Richter scale.

Share this project: