Scala examples for Kafka consumer

I’m new to Akka streams, Are there any Scala examples for streaming data from Kafka using Akka Stream and persisting Into Cassandra?

Have downloaded code from git.

However not sure how to proceed further.

Objective is to read csv/json file into Kafka and persist into Cassandra with alpakka

Hi @jsbilgi,

Sounds like a good start with Alpakka!

There is an example for reading from Kafka and writing to Elasticsearch which might help you to get started:

I hope that’s kind of what you were looking for,