Takes a logical decoding stream from postgresql and outputs it in a pluggable and safe way - View it on GitHub