iNaDeX / KafkaConsumer Public

Notifications You must be signed in to change notification settings
Fork 0
Star 3

Process streaming data from Kafka with Flink and store it in ElasticSearch

3 stars 0 forks Branches Tags Activity

Notifications

Name		Name	Last commit message	Last commit date
Latest commit History 15 Commits
screenshots		screenshots
src		src
.gitignore		.gitignore
initDatabase.sh		initDatabase.sh
kibanaDashboardExport.json		kibanaDashboardExport.json
negative-words.txt		negative-words.txt
pom.xml		pom.xml
positive-words.txt		positive-words.txt
readme.md		readme.md

Repository files navigation

Kafka Consumer Class

Behavior:

Subscribe to Kafka topic.
Process data (tweets) using Apache Flink streaming.
Compute several KPI of brand monitoring
Store results into ElasticSearch.
Display data in Kibana

About

Process streaming data from Kafka with Flink and store it in ElasticSearch

elasticsearch twitter kafka sentiment-analysis kafka-consumer flink flink-stream-processing flink-kafka

Report repository

Releases

No releases published

Packages

No packages published

Languages