You mentioned that replication is successful, so it cannot be an issue of blocked Replication Queues.
Also, as per above Code Snippet, you must be using Job Consumer.
Can you refer below Code Snippet, and see if you haven't missed anything. Also, please put loggers inside Job consumer, logging st...