Demonstrates how one can integrate kafka, flink and cassandra with spring data.
Please check the producer module in conjunction with this consumer for completion.
In the target architecture diagram shown below, this module implements kafka flink consumers that persist json events as entities in column families of cassandra using spring data cassandra.
Storage engine visualisation of column families stored in cassandra is as shown below