Function janus_kafka::noop_subscriber_ack_handler

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

Acknowledges each ack, if the result variant is an error, the error is propagated.