spark-redis conector for scala 2.11

499 Views Asked by At

I'am looking for a solution where I can save my kafka streaming RDD to Redis with zscore and in Append Mode. Do we have any Connector to do this - Tried spark redis connector by RedisLabs but it is only compatible with Scala 2.10 . There is one more github by Anchormen https://github.com/Anchormen/spark-redis-connector but it is again lacking documentation and also jar is not available on maven.

 collection.foreachRDD(rdd =>
      {
        if (!rdd.partitions.isEmpty) {
        // save rdd to redis as list with zscore 
        }
      })

So , any suggestions please. Thanks,

0

There are 0 best solutions below