How to collect a stream of changes (optionally with pre/post image), how to query it with CDC