**Expected Behavior** There should be support for Reactive and non Reactive code (with .block()). <!--- Tell us how it should work --> **Current Behavior** No native support <!--- Explain the difference from current behavior --> **Context** This [implementation can give a good inspiration.](https://github.com/spring-cloud/stream-applications/tree/main/applications/source/cdc-debezium-source). The current implementation that exists to MongoDb's change stream can be quite similar.