Spark streaming with mongoDB

My requirement is to read documents from mongo oplog (oplog.rs) using spark streaming. I could figure out the way to output from oplog but struck with how to make spark streaming read this. could u please help me with this.
Here is the code snippet for reading from oplog:


            final FindIterable<Document> documents = mc.getDatabase("local")
                    .getCollection("oplog.rs").find().filter(and(ne("op","n"),ne("op", "c"))).
                            sort(new Document("$natural", 1)).cursorType(CursorType.TailableAwait);

            documents.forEach((Block<Document>) document -> {
                System.out.println(document);
            });
        } .  ```