Fix

kafka-trainings · Jun 19, 2024 · 0c503a1 · 0c503a1
1 parent c8f88a9
commit 0c503a1
Show file tree

Hide file tree

Showing 6 changed files with 11 additions and 11 deletions.
diff --git a/kubernetes/csp1_consumer.yaml b/kubernetes/csp1_consumer.yaml
@@ -37,7 +37,7 @@ metadata:
 data:
   app.properties: |
     bootstrap.servers=kafka-kafka-bootstrap:9092
-    topic=csp1_transactions
+    topic=csp1.transactions
     group.id=csp1_consumer
     app.log.infos=true
     client.id=csp1_consumer
diff --git a/kubernetes/csp1_producer.yaml b/kubernetes/csp1_producer.yaml
@@ -37,7 +37,7 @@ metadata:
 data:
   app.properties: |
     bootstrap.servers=kafka-kafka-bootstrap:9092
-    topic=csp1_transactions
+    topic=csp1.transactions
     producer.msgs.per.sec=1
     app.log.infos=true
     client.id=csp1_producer
diff --git a/kubernetes/csp1_transformer.yaml b/kubernetes/csp1_transformer.yaml
@@ -37,7 +37,7 @@ metadata:
 data:
   app.properties: |
     bootstrap.servers=kafka-kafka-bootstrap:9092
-    csp1.topic=csp1_transactions
+    csp1.topic=csp1.transactions
     output.topic=transactions
     group.id=csp1_transformer
     transactional.id=transactions-transformer-app

diff --git a/kubernetes/csp2_producer.yaml b/kubernetes/csp2_producer.yaml
@@ -37,7 +37,7 @@ metadata:
 data:
   app.properties: |
     bootstrap.servers=kafka-kafka-bootstrap:9092
-    topic=csp2_transactions
+    topic=csp2.transactions
     producer.batch_interval.s=10
     producer.msgs_per_batch=100
     app.log.infos=true

diff --git a/kubernetes/csp2_transformer.yaml b/kubernetes/csp2_transformer.yaml
@@ -38,9 +38,9 @@ data:
   app.properties: |
     bootstrap.servers=kafka-kafka-bootstrap:9092
     application.id=csp2-transformer2
-    csp2.transactions.topic=csp2_transactions
-    csp2.customer_id_mapping.topic=csp2_customer_id_mapping
-    csp2.chargingstation_id_mapping.topic=csp2_chargingstation_id_mapping
+    csp2.transactions.topic=csp2.transactions
+    csp2.customer_id_mapping.topic=csp2.customer.id.mapping
+    csp2.chargingstation_id_mapping.topic=csp2.chargingstation.id.mapping
     output.topic=transactions
     processing.time.ms=100
     app.log.infos=true

diff --git a/kubernetes/topics.yaml b/kubernetes/topics.yaml
@@ -1,7 +1,7 @@
 apiVersion: kafka.strimzi.io/v1beta2
 kind: KafkaTopic
 metadata:
-  name: csp1_transactions
+  name: csp1.transactions
   labels:
     strimzi.io/cluster: kafka
 spec:
@@ -21,7 +21,7 @@ spec:
 apiVersion: kafka.strimzi.io/v1beta2
 kind: KafkaTopic
 metadata:
-  name: csp2_transactions
+  name: csp2.transactions
   labels:
     strimzi.io/cluster: kafka
 spec:
@@ -31,7 +31,7 @@ spec:
 apiVersion: kafka.strimzi.io/v1beta2
 kind: KafkaTopic
 metadata:
-  name: csp2_customer_id_mapping
+  name: csp2.customer.id.mapping
   labels:
     strimzi.io/cluster: kafka
 spec:
@@ -41,7 +41,7 @@ spec:
 apiVersion: kafka.strimzi.io/v1beta2
 kind: KafkaTopic
 metadata:
-  name: csp2_chargingstation_id_mapping
+  name: csp2.chargingstation.id.mapping
   labels:
     strimzi.io/cluster: kafka
 spec: