How to read the Postgresql's WAL from a specific LSN using Postgrex.ReplicationConnection?

I am willing to use Postgrex.ReplicationConnection publish the Postgresql’s Changes to a broker, but i would like to handle errors and if is it possible to use Postgrex.ReplicationConnection to read the Postgresql’s WAL changes from a specific LSN when an error occur in my app logic?
Thank you in advance?

1 Like