Function janus_kafka::instrumented_subscriber_ack_handler

pub async fn instrumented_subscriber_ack_handler<M, A>(
    handler: A, 
    opts: Opts
) -> Result<(), KafkaError> where
    M: MessageExt,
    A: AckHandler<Output = Result<M, (M, KafkaError)>, Error = KafkaError>, 

This is supported on crate feature instrumented only.

For each ack increments a metric depending on the variant in the result. A convenience function to continuously processes acks until an error is encountered.