I was pushing both New and old transaction ID in Kafka, meaning all unverified transaction would be in queue.