diff --git a/.ksql/CONNECTORS/GEOLOCATION_01_STREETNAME_OSLO_CONNECTOR.ksql b/.ksql/CONNECTORS/GEOLOCATION_01_STREETNAME_OSLO_CONNECTOR.ksql new file mode 100644 index 000000000..d4ecb55a9 --- /dev/null +++ b/.ksql/CONNECTORS/GEOLOCATION_01_STREETNAME_OSLO_CONNECTOR.ksql @@ -0,0 +1,28 @@ +CREATE SINK CONNECTOR `StreetNameOsloGeolocationConnector` with ( + "topics"= 'streetname.snapshot.oslo.flatten.geolocation', + "input.data.format"= 'JSON_SR', + "input.key.format"= 'JSON_SR', + "delete.enabled"= false, + "connector.class"= 'MicrosoftSqlServerSink', + "name"= 'StreetNameOsloGeolocationConnector', + "kafka.auth.mode"= 'KAFKA_API_KEY', + "kafka.api.key"= '***', + "kafka.api.secret"= '***', + "connection.host"= '***', + "connection.port"= '1433', + "connection.user"= 'geolocation', + "connection.password"= '***', + "db.name"= 'vbr-wms', + "ssl.mode"= 'require', + "insert.mode"= 'UPSERT', + "table.name.format"= 'vbr-wms.geolocation.StreetNameOsloGeolocation', + "table.types"= 'TABLE', + "db.timezone"= 'UTC', + "pk.mode"= 'record_key', + "pk.fields"= 'msgkey', + "auto.create"= true, + "auto.evolve"= true, + "quote.sql.identifiers"= 'ALWAYS', + "batch.sizes"= 3000, + "tasks.max"= 1 + ); \ No newline at end of file diff --git a/.ksql/CONNECTORS/GRB_01_STREETNAME_OSLO_CONNECTOR.ksql b/.ksql/CONNECTORS/GRB_01_STREETNAME_OSLO_CONNECTOR.ksql index 9fd4ba42e..cf3275022 100644 --- a/.ksql/CONNECTORS/GRB_01_STREETNAME_OSLO_CONNECTOR.ksql +++ b/.ksql/CONNECTORS/GRB_01_STREETNAME_OSLO_CONNECTOR.ksql @@ -6,9 +6,9 @@ CREATE SINK CONNECTOR `StreetNameOsloGrbConnector` with ( "connector.class"= 'MicrosoftSqlServerSink', "name"= 'StreetNameOsloGrbConnector', "kafka.auth.mode"= 'KAFKA_API_KEY', - "kafka.api.key"= 'DZKR6A5UYAZDBARE', + "kafka.api.key"= '***', "kafka.api.secret"= '***', - "connection.host"= 'aiv-beta-grb-basisregisters-db.database.windows.net', + "connection.host"= '***', "connection.port"= '1433', "connection.user"= 'GR', "connection.password"= '***',