kafka-elasticSearch-realtime-tweets-processing
Used Twitter api to get a realtime tweets to kafka using a kafka-producer then consume those tweets as a json objects using a kafka-consumer and store them into elasticSearch which is hosted on AWS.
Consuming my Own Tweets
Commiting Offsets as a batch
Trigger a Shutdown Hook on The Twitter Producer
