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.
Log in or sign up for Devpost to join the conversation.