How we can handle records that are inProgress?

[meysamhadeli]

In traditional way (polling version), we mark our records as inProgress and processed and with this approach we only in subscription, get all inProgress records and do something and after that it can be processed.
But in new way with logical replication, we always get all records? How we mark records for processed or not? If we get all records in subscription and don't filter it base of delivered to somewhere, Will we always have a very heavy load to get all the records?