From 0c503a1b42f8af4c8ca5def4ce7fa7e1f2fca329 Mon Sep 17 00:00:00 2001 From: Anatoly Zelenin Date: Wed, 19 Jun 2024 11:57:31 +0000 Subject: [PATCH] Fix --- kubernetes/csp1_consumer.yaml | 2 +- kubernetes/csp1_producer.yaml | 2 +- kubernetes/csp1_transformer.yaml | 2 +- kubernetes/csp2_producer.yaml | 2 +- kubernetes/csp2_transformer.yaml | 6 +++--- kubernetes/topics.yaml | 8 ++++---- 6 files changed, 11 insertions(+), 11 deletions(-) diff --git a/kubernetes/csp1_consumer.yaml b/kubernetes/csp1_consumer.yaml index 365fcb3..5437dda 100644 --- 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 \ No newline at end of file diff --git a/kubernetes/csp1_producer.yaml b/kubernetes/csp1_producer.yaml index d462183..3778e5e 100644 --- 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 \ No newline at end of file diff --git a/kubernetes/csp1_transformer.yaml b/kubernetes/csp1_transformer.yaml index 4668512..e93ca30 100644 --- 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 index 529942b..397ec81 100644 --- 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 index bc90905..a120907 100644 --- 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 index 7b59bc7..7ba8189 100644 --- 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: