pub async fn run(config: WorkerConfig) -> Result<()>Expand description
Run one Postgres-to-Kafka connector until Ctrl-C and drain it gracefully.
ยงErrors
Returns an error for invalid configuration, startup failures, a connector runtime failure, health-server failure, or signal-listener failure.