The transaction id which is inserted and removed from the queue is not consistent across the function `consumeDmlRecordsByTopic`.

Impact of this is test was running for 7 minutes. The test however, passes since the SourceRecord corresponding to insert statement is anyway returned back from this function after 30 seconds. Reason for this long time is because the initially inserted transaction id was not being removed from the queue, since the attempt to remove it were made with a different format of the same transaction id.

Post the fix, test works in 9 seonds.