Fix for nsq batch river