Add concurrent user tracking to streamlogs collector