behindRetention method

Future<bool> behindRetention()

Whether this consumer stands before what the log has pruned, so delivery cannot reach what it missed and only a backfill can (DV-CDC-002).

Implementation

Future<bool> behindRetention() async {
  final int? at = await position();
  return at != null && at < (await capture._state()).pruned;
}