fn progress_search<C: ConsumerContext + 'static>(
progress_client_read_committed: &BaseConsumer<C>,
progress_record_fetch_timeout: Duration,
progress_topic: &str,
partition: i32,
lo: i64,
hi: i64,
progress_key: ProgressKey,
child_token: Weak<()>,
metrics: Arc<KafkaSinkMetrics>,
) -> Result<Option<ProgressRecord>>