Home

Introduction

The purpose of this repository is to demonstrates how one can integrate kafka, flink and cassandra with spring data. Kindly refer to the consumer module along with the producer module to have a full understanding of the solution designed.

Functional overview

The producer is designed to read a bundled CSV file and publish JSON messages into a kafka broker.

Pre-requisite

• A kafka broker that's up and running. Refer to the page that describes how one can set-up a broker on a local kafka cluster.