我正在尝试使用flink流功能读/写mongodb。我已经用flink的 RichSinkFunction 班级。我试着用对面Flink的课来读， RichSourceFunction . 然而，似乎不可能一个接一个地从mongodb流式传输文档，同时跟踪数据库上的当前“位置”。
我想知道你们中是否有人知道有什么方法可以做到这一点。我知道mongodb的发布/订阅功能，但是我更希望避免这种方法。