scala - scala 2.11 的 spark-redis 连接器

Question

我正在寻找一种解决方案，我可以使用 zscore 和附加模式将我的 kafka 流式 RDD 保存到 Redis。Do we have any Connector to do this - RedisLabs 尝试了 spark redis 连接器，但它仅与 Scala 2.10 兼容。Anchormen 的另一个 github https://github.com/Anchormen/spark-redis-connector但它再次缺乏文档，并且 jar 在 maven 上不可用。

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

所以，请有任何建议。谢谢，