raw streaming api consumer in place