Support exactly-once semantic for Postgres connector. As providing EOS for snapshotting phase needs more thinking (and possibly not that much required by users), as the first step support EOS only during streaming phase.