Analysis on Corona Virus tweets Using Kafka, Spark, S3, and ElasticSearch

Built a Kafka producer to store tweets inside a kafka topics. Built Kafka consumer to store the json data in S3 and ElasticSearch.

Also processed the data using Spark Direct Streaming in Python

Name		Name	Last commit message	Last commit date
Latest commit History 8 Commits
.ipynb_checkpoints		.ipynb_checkpoints
KafkaBasics		KafkaBasics
KafkaConsumerToS3		KafkaConsumerToS3
KafkaElasticSearchConsumer		KafkaElasticSearchConsumer
KafkaTwitterProducer		KafkaTwitterProducer
target/classes		target/classes
Kafka_project.iml		Kafka_project.iml
README.md		README.md
Streaming Kafka Topic Data using Spark.ipynb		Streaming Kafka Topic Data using Spark.ipynb
pom.xml		pom.xml

Provide feedback