added support for multiple ES consumers