Fmutex hanging issue with elasticsearch + rabbitmq river + large dataset (>100M records)