This repo will provide sample to consume Mongo API's ChangeStream in Java - View it on GitHub