As per comment above, we should use factory.consumer_manager().get_consumer(consumer_id) instead.