The sink connector already supports cps.useEmulator, but the source connector does not. When cps.useEmulator=true, the source connector still attempts to connect to production Pub/Sub, or fails during startup.
I propose adding emulator support to the source connector, consistent with the sink connector.
Here is the PR that added emulator support to the sink connector: #399
The sink connector already supports
cps.useEmulator, but the source connector does not. Whencps.useEmulator=true, the source connector still attempts to connect to production Pub/Sub, or fails during startup.I propose adding emulator support to the source connector, consistent with the sink connector.
Here is the PR that added emulator support to the sink connector: #399