Run stream consumers in separate actor