final Thread t =
    new Thread(
        () -> {
          try {
            for (final ChangeStreamDocument<Document> doc : collection.watch()) {
              System.out.println(doc);
            }
          } catch (final MongoInterruptedException e) {
           System.out.println("interrupted");
          }
        });

t.start();

Thread.sleep(1000);

t.interrupt();
t.join();