Akka Stream based library for unsupported and no longer maintained versions of Cassandra and DataStax Enterprise powered by Netflix Astyanax
Please prefer alpakka Cassandra Connector for version 2 and above
Have a look at the presentation of this lightning talk about Cassandra migration to understand the reason behind this library
Add the jcenter repository in your build definition and import the latest stable version
resolvers += Resolver.jcenterRepo
libraryDependencies ++= Seq(
"com.github.niqdev" %% "akka-stream-cassandra" % "0.7.5"
// you might prefer to use a different version
exclude("com.netflix.astyanax", "astyanax")
)implicit val actorSystem: ActorSystem = ActorSystem("actor-system")
implicit val materializer: ActorMaterializer = ActorMaterializer()
implicit val executionContext: ExecutionContext = actorSystem.dispatcher
val keyspace: Keyspace = ...
val columnFamily: ColumnFamily[String, String] = ...
CassandraSource(keyspace, columnFamily)
.via(...)
.runForeach { row =>
log.debug(s"row: ${row.getKey}")
}Refer to the test for a full example with EmbeddedCassandra