Apache Kafka Java Examples

Stream real time Tweets of current affairs like covid-19 using Kafka 2.0.0 high throughput producer & consumer into Elasticsearch using safe, idempotent and compression configurations. Aggregate the data and use it for further analytics.

This application streams real time tweets by any topic(s) using Twitter Hosebird Client that is build on kafka.

Stay connected with the latest news and events, connect with friends and family, and share your own thoughts and opinions with the Twitter App for Android.

The class project of Big Data Technology course in March 2018 at MUM

Retrieves last tweets that contains some keyword and prints them

A lossy counting algorithm implemented to determine the top trending hashtags using the Twitter API to get a continuous stream of tweets.

Spring WebFlux Implementation of Twitter Labs Streaming APIs

A sample project with a kafka producer who fetches data from twitter and sends it to a topic consumed by an application that puts data into elasticsearch.

a demo project to Analyze most popular twitter hashtags using Java 8 Spring-Boot Spark Streaming Kafka & Docker Demo.

Experimentations with Kafka

A simple Android project showing realtime tweets around user on Google Map

Exploring Twitter Data using Elasticseach & Kibana's Canvas.

Twitter stream processing with Kafka and Apache Beam

This is me downloading tweets in real time with the Streaming API, which I access through the Java library Hosebird Client, and saving them in a MongoDB, all mediated through Apache Kafka brokers that make things great.

A Kafka client that fetches tweets using Twitter Streaming API and sends them to Kafka.

Near real-time Twitter data streaming using Apache Flink

spring-boot

Twitter data analysis using hadoop (hdfs), flume, map-reduce and hive. Sentiment Analysis is also done using affin dictionary for tweets related to Indian election.

Collects data about users on Twitter (using Twitter Streaming API and MongoDB) and detects communities (using Gephi).