These logs should include data and control message flow. They should be disabled by default. They can be enabled with db.setLogLevel for debugging purposes.

Also, fix the logs in ChangeStreamSourceOperator that do not have the context.