Csv -> RabitMQ -> Cassandra using Akka

Akka Libraries Akka Streams & Alpakka
1

Hi Team,

Using below code from “https://github.com/abhsrivastava/AlpakkaAMQP” as producer.

AlpakkaAMQPPublisher.scala

It reads csv file and loads data into rabitMQ.

Have requirement to load this data into cassandra using akka.

Would you please suggest if there are any examples to refer

Thanks and regards

Jagannath S Bilgi

2

@jsbilgi have you seen the Alpakka Cassandra connector documentation?

https://doc.akka.io/docs/alpakka/current/cassandra.html

I doubt that there’s an existing example of the specific combination you need, but Alpakka connectors are designed to be modular and composable.