pub async fn prepare(
contract: &Contract,
endpoint: &Endpoint,
) -> Result<PreparedLoad, ConsumerError>Expand description
Join every consumer group before starting the measured load and its fault clock, so coordinator startup does not age the first produced records.
ยงErrors
Returns a consumer startup error before any producer starts.