pub fn create_source_worker_async(
source: Source,
managed_sources: &mut HashMap<SourceId, ConnectorSourceWorkerHandle>,
metrics: Arc<MetaMetrics>,
) -> MetaResult<()>
Expand description
Used on startup (SourceManager::new
). Failed sources will not block meta startup.