Skip to content

Commit

Permalink
Fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
disrupted committed Oct 25, 2023
1 parent 1b0e89a commit 52d9b13
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
4 changes: 2 additions & 2 deletions examples/bakdata/atm-fraud-detection/config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
20 changes: 10 additions & 10 deletions tests/pipeline/snapshots/snap_test_example.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
},
Expand Down Expand Up @@ -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
},
Expand Down Expand Up @@ -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',
Expand Down Expand Up @@ -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',
Expand Down Expand Up @@ -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': [
Expand All @@ -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': {
Expand Down

0 comments on commit 52d9b13

Please sign in to comment.