Create and update a Pulsar IO source connector via pulsar-admin

Steps

1. List available built-in source connector types: pulsar-admin sources available-sources — this shows connectors packaged with your Pulsar distribution (e.g., kafka, rabbitmq, mqtt, debezium-postgres).
2. Create a source connector: pulsar-admin sources create --name {source-name} --source-type {type} --destination-topic-name persistent://{tenant}/{namespace}/{topic} --source-config-file {config.yaml} where config.yaml contains connector-specific settings.
3. For a Debezium Postgres source, the config file must include database.hostname, database.port, database.user, database.password, database.dbname, and plugin.name (e.g., pgoutput); check current Pulsar IO Debezium docs for the full required field list.
4. Check source status: pulsar-admin sources status --name {source-name} --namespace {tenant}/{namespace}
5. Update source configuration without recreating: pulsar-admin sources update --name {source-name} --source-config-file {updated-config.yaml}