mongodb 更改流无法解析订阅答案

【问题标题】：mongodb change stream cannot resolve subscribemongodb 更改流无法解析订阅
【发布时间】：2019-10-09 19:33:54
【问题描述】：

我想在 mongo db 上设置一个更改流，但是有一个“无法解决重载方法订阅”，我无法找到问题的根源：

import org.mongodb.scala.{Document, MongoClient, MongoCollection, MongoDatabase}

object App {

  def main(args: Array[String]): Unit = {

      val mongoClient: MongoClient = MongoClient("mongodb://localhost")

      val database: MongoDatabase = mongoClient.getDatabase("db")

      val collection: MongoCollection[Document] = database.getCollection("col")
          collection.watch().subscribe(
            (doc: Document) => println(doc.toJson),
            (t: Throwable) => println(""),
              () => println()
          )
  }

}


libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "2.7.0"

【问题讨论】：

标签： mongodb scala changestream

【解决方案1】：

替换：

(doc: Document) => println(doc.toJson),

与：

(csd: ChangeStreamDocument[Document]) => println(csd.getFullDocument()),

【讨论】：

再次感谢 Senjin，但是再次，流没有开始......