Data collection and storage

As briefly explained in Overview of the Project, we will use Twitter4j library to collect Twitter’s stream data, publish this data to Kafka, then save it in Cassandra database. The details about how to publish Twitter’s data to Kafka can

Connecting Kafka to Cassandra Sink

The connection of Kafka to other databases is normally divided into Source Connector and Sink Connector. Source Connector is used to read data from Databases and publish it to Kafka broker while Sink Connector is used to write from Kafka