Switch RecordsStreamProducer to use non-blocking stream call

Flushing LSN from a separate thread seems to be unsafe as the org.postgresql.replication.PGReplicationStream is not thread safe.

This issue will try to swtich to non-blocking read of message and updating of LSN inisde the same thread loop.