Merge branch 'v3' into refactor/template-print

bakdata · Oct 25, 2023 · 99d30a9 · 99d30a9
2 parents 24fdef5 + 52d9b13
commit 99d30a9
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/examples/bakdata/atm-fraud-detection/config.yaml b/examples/bakdata/atm-fraud-detection/config.yaml
@@ -4,11 +4,11 @@ topic_name_config:
   default_error_topic_name: "${pipeline_name}-${component_name}-dead-letter-topic"
   default_output_topic_name: "${pipeline_name}-${component_name}-topic"
 
-kafka_brokers: "http://k8kafka-cp-kafka-headless.${NAMESPACE}.svc.cluster.local:9092"
+kafka_brokers: "http://k8kafka-cp-kafka-headless.kpops.svc.cluster.local:9092"
 
 schema_registry:
   enabled: true
-  url: "http://k8kafka-cp-schema-registry.${NAMESPACE}.svc.cluster.local:8081"
+  url: "http://k8kafka-cp-schema-registry.kpops.svc.cluster.local:8081"
 
 kafka_rest:
   url: "http://localhost:8082"

diff --git a/tests/pipeline/snapshots/snap_test_example.py b/tests/pipeline/snapshots/snap_test_example.py
@@ -23,12 +23,12 @@
                 'replicaCount': 1,
                 'schedule': '0 12 * * *',
                 'streams': {
-                    'brokers': 'http://k8kafka-cp-kafka-headless.${NAMESPACE}.svc.cluster.local:9092',
+                    'brokers': 'http://k8kafka-cp-kafka-headless.kpops.svc.cluster.local:9092',
                     'extraOutputTopics': {
                     },
                     'optimizeLeaveGroupBehavior': False,
                     'outputTopic': 'bakdata-atm-fraud-detection-account-producer-topic',
-                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.${NAMESPACE}.svc.cluster.local:8081'
+                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.kpops.svc.cluster.local:8081'
                 },
                 'suspend': True
             },
@@ -74,12 +74,12 @@
                 'replicaCount': 1,
                 'schedule': '0 12 * * *',
                 'streams': {
-                    'brokers': 'http://k8kafka-cp-kafka-headless.${NAMESPACE}.svc.cluster.local:9092',
+                    'brokers': 'http://k8kafka-cp-kafka-headless.kpops.svc.cluster.local:9092',
                     'extraOutputTopics': {
                     },
                     'optimizeLeaveGroupBehavior': False,
                     'outputTopic': 'bakdata-atm-fraud-detection-transaction-avro-producer-topic',
-                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.${NAMESPACE}.svc.cluster.local:8081'
+                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.kpops.svc.cluster.local:8081'
                 },
                 'suspend': True
             },
@@ -129,14 +129,14 @@
                 },
                 'replicaCount': 1,
                 'streams': {
-                    'brokers': 'http://k8kafka-cp-kafka-headless.${NAMESPACE}.svc.cluster.local:9092',
+                    'brokers': 'http://k8kafka-cp-kafka-headless.kpops.svc.cluster.local:9092',
                     'errorTopic': 'bakdata-atm-fraud-detection-transaction-joiner-dead-letter-topic',
                     'inputTopics': [
                         'bakdata-atm-fraud-detection-transaction-avro-producer-topic'
                     ],
                     'optimizeLeaveGroupBehavior': False,
                     'outputTopic': 'bakdata-atm-fraud-detection-transaction-joiner-topic',
-                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.${NAMESPACE}.svc.cluster.local:8081'
+                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.kpops.svc.cluster.local:8081'
                 }
             },
             'name': 'transaction-joiner',
@@ -191,14 +191,14 @@
                 },
                 'replicaCount': 1,
                 'streams': {
-                    'brokers': 'http://k8kafka-cp-kafka-headless.${NAMESPACE}.svc.cluster.local:9092',
+                    'brokers': 'http://k8kafka-cp-kafka-headless.kpops.svc.cluster.local:9092',
                     'errorTopic': 'bakdata-atm-fraud-detection-fraud-detector-dead-letter-topic',
                     'inputTopics': [
                         'bakdata-atm-fraud-detection-transaction-joiner-topic'
                     ],
                     'optimizeLeaveGroupBehavior': False,
                     'outputTopic': 'bakdata-atm-fraud-detection-fraud-detector-topic',
-                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.${NAMESPACE}.svc.cluster.local:8081'
+                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.kpops.svc.cluster.local:8081'
                 }
             },
             'name': 'fraud-detector',
@@ -253,7 +253,7 @@
                 },
                 'replicaCount': 1,
                 'streams': {
-                    'brokers': 'http://k8kafka-cp-kafka-headless.${NAMESPACE}.svc.cluster.local:9092',
+                    'brokers': 'http://k8kafka-cp-kafka-headless.kpops.svc.cluster.local:9092',
                     'errorTopic': 'bakdata-atm-fraud-detection-account-linker-dead-letter-topic',
                     'extraInputTopics': {
                         'accounts': [
@@ -265,7 +265,7 @@
                     ],
                     'optimizeLeaveGroupBehavior': False,
                     'outputTopic': 'bakdata-atm-fraud-detection-account-linker-topic',
-                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.${NAMESPACE}.svc.cluster.local:8081'
+                    'schemaRegistryUrl': 'http://k8kafka-cp-schema-registry.kpops.svc.cluster.local:8081'
                 }
             },
             'from': {