Function queue 

pub fn queue(
    config: &Config,
    client: Arc<KafkaClient>,
    locks: LockManager,
) -> Result<KafkaQueue>

The queue KAFKA_GROUP and KAFKA_TOPIC_PREFIX describe.

Errors

When locks is not backed by a shared store — see KafkaQueue::new.