September 2017
Beginner to intermediate
360 pages
8h 13m
English
To run the example, you have to run the data generator; DataGenerator, which pushes the data into the Kafka topic and then the Flink program that is FlinkCassandraConnector reads it from the Kafka topic and pushes it into Cassandra.
Input:
Run the program in Eclipse and it will show the following screenshot on the console. The data set will be different as it is random.

Output:
After running FlinkCassandraConnector, nothing will be printed on the console but you have to check whether data is present in Cassandra or not. So run the following query shown in the screenshot:
Read now
Unlock full access