After running a few pipelines the CPU spike to 200%. Attached thread dump of the process after a 10 minute delay.
Fixing a bug which can cause a thread spinning in an infinite while loop due to multi thread consumers on a queue that allows a single consumer.