beginning of the consumer and producer API for processing audit records.