Fix internal SQRL Kafka server variable name (#77)

ferenc-csaky · web-flow · commit ccf8a08268d6 · 2025-09-29T13:36:49.000+02:00
diff --git a/clickstream-ai-recommendation/clickstream-kafka/clickstream.table.sql b/clickstream-ai-recommendation/clickstream-kafka/clickstream.table.sql
@@ -6,7 +6,7 @@ CREATE TABLE Clickstream (
 ) WITH (
     'connector' = 'kafka',
     'topic' = 'clickstream',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'clickstream-group',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
diff --git a/clickstream-ai-recommendation/content-kafka/content.table.sql b/clickstream-ai-recommendation/content-kafka/content.table.sql
@@ -7,9 +7,9 @@ CREATE TABLE Content (
 ) WITH (
     'connector' = 'kafka',
     'topic' = 'content',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'clickstream-group',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'format' = 'flexible-json'
-    );
+    );
diff --git a/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/card_assignment.table.sql b/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/card_assignment.table.sql
@@ -6,7 +6,7 @@ CREATE TABLE CardAssignment (
     WATERMARK FOR `timestamp` AS `timestamp` - INTERVAL '1' SECOND
 ) WITH (
       'connector' = 'kafka',
-      'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+      'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
       'properties.group.id' = 'mygroupid',
       'scan.startup.mode' = 'group-offsets',
       'properties.auto.offset.reset' = 'earliest',
diff --git a/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/merchant.table.sql b/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/merchant.table.sql
@@ -6,10 +6,10 @@ CREATE TABLE Merchant (
     WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
 ) WITH (
     'connector' = 'kafka',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'mygroupid',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'value.format' = 'flexible-json',
     'topic' = 'merchant'
-    );
+    );
diff --git a/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/merchant_reward.table.sql b/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/merchant_reward.table.sql
@@ -10,10 +10,10 @@ CREATE TABLE MerchantReward (
     WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
 ) WITH (
     'connector' = 'kafka',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'mygroupid',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'value.format' = 'flexible-json',
     'topic' = 'merchantreward'
-    );
+    );
diff --git a/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/transaction.table.sql b/finance-credit-card-chatbot/credit-card-analytics/creditcard-kafka/transaction.table.sql
@@ -7,10 +7,10 @@ CREATE TABLE Transaction (
     WATERMARK FOR `time` AS `time` - INTERVAL '1' SECOND
 ) WITH (
       'connector' = 'kafka',
-      'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+      'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
       'properties.group.id' = 'mygroupid',
       'scan.startup.mode' = 'group-offsets',
       'properties.auto.offset.reset' = 'earliest',
       'value.format' = 'flexible-json',
       'topic' = 'transaction'
-      );
+      );
diff --git a/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/card_assignment.table.sql b/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/card_assignment.table.sql
@@ -6,7 +6,7 @@ CREATE TABLE CardAssignment (
     WATERMARK FOR `timestamp` AS `timestamp` - INTERVAL '1' SECOND
 ) WITH (
       'connector' = 'kafka',
-      'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+      'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
       'properties.group.id' = 'mygroupid',
       'scan.startup.mode' = 'group-offsets',
       'properties.auto.offset.reset' = 'earliest',
diff --git a/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/merchant.table.sql b/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/merchant.table.sql
@@ -6,10 +6,10 @@ CREATE TABLE Merchant (
     WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
 ) WITH (
     'connector' = 'kafka',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'mygroupid',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'value.format' = 'flexible-json',
     'topic' = 'merchant'
-    );
+    );
diff --git a/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/merchant_reward.table.sql b/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/merchant_reward.table.sql
@@ -10,10 +10,10 @@ CREATE TABLE MerchantReward (
     WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
 ) WITH (
     'connector' = 'kafka',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'mygroupid',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'value.format' = 'flexible-json',
     'topic' = 'merchantreward'
-    );
+    );
diff --git a/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/transaction.table.sql b/finance-credit-card-chatbot/credit-card-rewards/creditcard-kafka/transaction.table.sql
@@ -7,10 +7,10 @@ CREATE TABLE Transaction (
     WATERMARK FOR `time` AS `time` - INTERVAL '1' SECOND
 ) WITH (
       'connector' = 'kafka',
-      'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+      'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
       'properties.group.id' = 'mygroupid',
       'scan.startup.mode' = 'group-offsets',
       'properties.auto.offset.reset' = 'earliest',
       'value.format' = 'flexible-json',
       'topic' = 'transaction'
-      );
+      );
diff --git a/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/card_assignment.table.sql b/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/card_assignment.table.sql
@@ -6,7 +6,7 @@ CREATE TABLE CardAssignment (
     WATERMARK FOR `timestamp` AS `timestamp` - INTERVAL '1' SECOND
 ) WITH (
       'connector' = 'kafka',
-      'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+      'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
       'properties.group.id' = 'mygroupid',
       'scan.startup.mode' = 'group-offsets',
       'properties.auto.offset.reset' = 'earliest',
diff --git a/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/merchant.table.sql b/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/merchant.table.sql
@@ -6,10 +6,10 @@ CREATE TABLE Merchant (
     WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
 ) WITH (
     'connector' = 'kafka',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'mygroupid',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'value.format' = 'flexible-json',
     'topic' = 'merchant'
-    );
+    );
diff --git a/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/merchant_reward.table.sql b/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/merchant_reward.table.sql
@@ -10,10 +10,10 @@ CREATE TABLE MerchantReward (
     WATERMARK FOR `updatedTime` AS `updatedTime` - INTERVAL '1' SECOND
 ) WITH (
     'connector' = 'kafka',
-    'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+    'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
     'properties.group.id' = 'mygroupid',
     'scan.startup.mode' = 'group-offsets',
     'properties.auto.offset.reset' = 'earliest',
     'value.format' = 'flexible-json',
     'topic' = 'merchantreward'
-    );
+    );
diff --git a/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/transaction.table.sql b/finance-credit-card-chatbot/credit-card-views/creditcard-kafka/transaction.table.sql
@@ -7,10 +7,10 @@ CREATE TABLE Transaction (
     WATERMARK FOR `time` AS `time` - INTERVAL '1' SECOND
 ) WITH (
       'connector' = 'kafka',
-      'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+      'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
       'properties.group.id' = 'mygroupid',
       'scan.startup.mode' = 'group-offsets',
       'properties.auto.offset.reset' = 'earliest',
       'value.format' = 'flexible-json',
       'topic' = 'transaction'
-      );
+      );
diff --git a/healthcare-study/healthcare-study-stream/metrics-kafka/enriched_indicator.table.sql b/healthcare-study/healthcare-study-stream/metrics-kafka/enriched_indicator.table.sql
@@ -3,7 +3,7 @@ CREATE TABLE EnrichedIndicators (
 ) WITH (
       'connector' = 'kafka',
       'topic' = 'enrichedindicators',
-      'properties.bootstrap.servers' = '${PROPERTIES_BOOTSTRAP_SERVERS}',
+      'properties.bootstrap.servers' = '${KAFKA_BOOTSTRAP_SERVERS}',
       'properties.group.id' = 'mygroup',
       'scan.startup.mode' = 'earliest-offset',
       'value.format' = 'flexible-json',
