Skip to main content

resolve_consumer_group

Function resolve_consumer_group 

Source
pub fn resolve_consumer_group<R: MessageRouter>(
    explicit: Option<&str>,
    router: &R,
    transport: &str,
) -> Result<String, TransportError>
Expand description

Resolve a consumer group from an explicit value or the router identity, validating the result.