/flink-kafka-consumer

Demonstrates how one can integrate kafka, flink and cassandra with spring data. Please check the producer module in conjuction with the consumer for completion.

Primary LanguageJava

Description

Demonstrates how one can integrate kafka, flink and cassandra with spring data.

Please check the producer module in conjunction with this consumer for completion.

Target architecture

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.

Target architecture

Data model

Storage engine visualisation of column families stored in cassandra is as shown below

Data model