A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud
APACHE-2.0 License
java
Tweet Collector to collect real-time tweets with Twitter Streaming APIKafka
clusterApache Flink
Streaming to process (parse, filter and tranform) tweetsElasticsearch
for data persistance and indexSpringBoot
RESTful API server
to query tweets from ElasticsearchAngular
web applicationKibana
Docker
image and deploy microservices
to Kubernetes
clustertweet-collector: collect real-time tweets with Twitter Streaming API and push to Kafka cluster.
rest-api-server: A RESTful API server querying tweets from Elasticsearch using SpringBoot framework.
flink-processor: Streaming process tweets and ingest into Elasticsearch.
frontend-website: Visualize Tweet Map with Angular framework. (developing)
JDK version:
./gradlew :tweet-collector:clean :tweet-collector:build :tweet-collector:dockerPush
java -jar tweet-collector/build/libs/tweet-collector-1.1-SNAPSHOT.jar
./gradlew :flink-processor:clean :flink-processor:build