Rename the connector
@@ -72,7 +72,7 @@ pub(crate) struct Builder {}
#[async_trait::async_trait]
impl ConnectorBuilder for Builder {
fn connector_type(&self) -> ConnectorType {
- "gpubsub-consumer".into()
+ "gpubsub_consumer".into()
}
async fn build(&self, alias: &str, raw_config: &ConnectorConfig) -> Result<Box<dyn Connector>> {
