Hiya, might take to next week to get back to you due to current workforce/workload. Kafka comms are async, I suspect we no longer correctly identify an ongoing transaction with the custom consumer when you install the factory. You may be able to trace the methods your factory produces and get the correct timings