From b37fcf6ad32786685d37d48106492e4d49da8a63 Mon Sep 17 00:00:00 2001
From: emalfroy <egon.malfroy@gmail.com>
Date: Wed, 27 Sep 2023 10:46:13 +0200
Subject: [PATCH] =?UTF-8?q?chore:=20add=20geolocation=20ksql=C3=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ...LOCATION_01_STREETNAME_OSLO_CONNECTOR.ksql | 28 +++++++++++++++++++
 .../GRB_01_STREETNAME_OSLO_CONNECTOR.ksql     |  4 +--
 2 files changed, 30 insertions(+), 2 deletions(-)
 create mode 100644 .ksql/CONNECTORS/GEOLOCATION_01_STREETNAME_OSLO_CONNECTOR.ksql

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"= '***',