scala - Kafka Spark Stream 直接保存到 Redis

Question

我正在使用 Scala 获取 kafkaStream 并希望将此数据直接插入到 Redis。这样做的最佳最佳策略是什么？

val kafkaStream = KafkaUtils.createStream(ssc, "192.168.0.40:2181", "group", topics, StorageLevel.MEMORY_AND_DISK)

早些时候我试图使用https://github.com/debasishg/scala-redis但这不适用于 Spark，所以我必须收集 RDD，然后将记录保存到 Redis 中，这在我的项目中产生了很多开销。所以寻找一些解决方案，我可以直接将这串消息推送到 Redis 中，并且还想维护 ZScore。

谢谢，