In KAFKA-306 the logic was simplified by using poll.await.time.ms via ChangeStreamIterable.maxAwaitTime instead of blocking in the MongoSourceTask.poll().
The documentation of the configuration should be updated in the code as well as: https://www.mongodb.com/docs/kafka-connector/current/source-connector/configuration-properties/change-stream/