summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormpriyank <priyank.maheshwari@est.tech>2023-04-21 15:24:10 +0100
committermpriyank <priyank.maheshwari@est.tech>2023-04-24 16:30:39 +0100
commit6fc407db4f8cf62fcf6ce2fba332cdb9a8762bf2 (patch)
treec555c744a3a99a9c6bba1b2f9b6ffc8d778b3ead
parenta336bf408d5821aae5d19fcd27bd54dd7246b82d (diff)
[CPS] Parameterize topics in application
- parameterize the topics for both cps-ncmp and ncmp-dmi-plugin code - Also copy the globally defined topics to the more specific place. - In the next patch will remove the global topics and users info. Issue-ID: CPS-1612 Change-Id: Ibf38dd96857ed50a101279a11ded915f86be3d65 Signed-off-by: mpriyank <priyank.maheshwari@est.tech>
-rw-r--r--kubernetes/cps/components/cps-core/resources/config/application-helm.yml5
-rw-r--r--kubernetes/cps/components/cps-core/values.yaml25
-rw-r--r--kubernetes/cps/components/ncmp-dmi-plugin/resources/config/application-helm.yml5
-rw-r--r--kubernetes/cps/components/ncmp-dmi-plugin/values.yaml25
4 files changed, 52 insertions, 8 deletions
diff --git a/kubernetes/cps/components/cps-core/resources/config/application-helm.yml b/kubernetes/cps/components/cps-core/resources/config/application-helm.yml
index fd3068e6a6..842395f71e 100644
--- a/kubernetes/cps/components/cps-core/resources/config/application-helm.yml
+++ b/kubernetes/cps/components/cps-core/resources/config/application-helm.yml
@@ -62,6 +62,11 @@ spring.kafka.security.protocol: SASL_PLAINTEXT
spring.kafka.properties.sasl.mechanism: {{ .Values.kafkaUser.authenticationType | upper }}
spring.kafka.properties.sasl.jaas.config: ${SASL_JAAS_CONFIG}
+# Kafka Topics
+{{- if .Values.topics.config }}
+{{ toYaml .Values.topics.config | nindent 2 }}
+{{- end }}
+
{{- if .Values.config.additional }}
{{ toYaml .Values.config.additional | nindent 2 }}
{{- end }}
diff --git a/kubernetes/cps/components/cps-core/values.yaml b/kubernetes/cps/components/cps-core/values.yaml
index e5c062ccf0..96d53f5aff 100644
--- a/kubernetes/cps/components/cps-core/values.yaml
+++ b/kubernetes/cps/components/cps-core/values.yaml
@@ -192,7 +192,18 @@ config:
notification.async.executor.wait-for-tasks-to-complete-on-shutdown: true
notification.async.executor.thread-name-prefix: Async-
-# Strimzi KafkaUser config
+# Strimzi KafkaUser and Topic config
+kafkaTopic:
+ - name: &dmiCmEventsTopic dmi-cm-events
+ retentionMs: 7200000
+ segmentBytes: 1073741824
+ - name: &ncmpAsyncM2MTopic ncmp-async-m2m
+ retentionMs: 7200000
+ segmentBytes: 1073741824
+ - name: &cmAvcSubscriptionTopic cm-avc-subscription
+ retentionMs: 7200000
+ segmentBytes: 1073741824
+
kafkaUser:
authenticationType: scram-sha-512
acls:
@@ -202,16 +213,22 @@ kafkaUser:
- name: *dataUpdatedTopic
type: topic
operations: [Write]
- - name: dmi-cm-events
+ - name: *dmiCmEventsTopic
type: topic
operations: [Read]
- - name: ncmp-async-m2m
+ - name: *ncmpAsyncM2MTopic
type: topic
operations: [Read]
- - name: cm-avc-subscription
+ - name: *cmAvcSubscriptionTopic
type: topic
operations: [Read]
+topics:
+ config:
+ app.ncmp.async-m2m.topic: *ncmpAsyncM2MTopic
+ app.ncmp.avc.subscription-topic: *cmAvcSubscriptionTopic
+ app.dmi.cm-events.topic: *dmiCmEventsTopic
+
logging:
level: INFO
path: /tmp
diff --git a/kubernetes/cps/components/ncmp-dmi-plugin/resources/config/application-helm.yml b/kubernetes/cps/components/ncmp-dmi-plugin/resources/config/application-helm.yml
index 7d764bf589..428a553de6 100644
--- a/kubernetes/cps/components/ncmp-dmi-plugin/resources/config/application-helm.yml
+++ b/kubernetes/cps/components/ncmp-dmi-plugin/resources/config/application-helm.yml
@@ -57,6 +57,11 @@ spring.kafka.security.protocol: SASL_PLAINTEXT
spring.kafka.properties.sasl.mechanism: {{ .Values.kafkaUser.authenticationType | upper }}
spring.kafka.properties.sasl.jaas.config: ${SASL_JAAS_CONFIG}
+# Kafka Topics
+{{- if .Values.topics.config }}
+{{ toYaml .Values.topics.config | nindent 2 }}
+{{- end }}
+
{{- if .Values.config.additional }}
{{ toYaml .Values.config.additional | nindent 2 }}
{{- end }}
diff --git a/kubernetes/cps/components/ncmp-dmi-plugin/values.yaml b/kubernetes/cps/components/ncmp-dmi-plugin/values.yaml
index 59a64905d1..fcc4808098 100644
--- a/kubernetes/cps/components/ncmp-dmi-plugin/values.yaml
+++ b/kubernetes/cps/components/ncmp-dmi-plugin/values.yaml
@@ -178,19 +178,36 @@ updateStrategy:
maxUnavailable: 0
maxSurge: 1
-# Strimzi KafkaUser config
+# Strimzi KafkaUser and Topic config
+kafkaTopic:
+ - name: &ncmpDmiCmAvcSubscriptionNcmpDmiPluginTopic ncmp-dmi-cm-avc-subscription-ncmp-dmi-plugin
+ retentionMs: 7200000
+ segmentBytes: 1073741824
+ - name: &dmiNcmpCmAvcSubscriptionTopic dmi-ncmp-cm-avc-subscription
+ retentionMs: 7200000
+ segmentBytes: 1073741824
+ - name: &ncmpAsyncM2MTopic ncmp-async-m2m
+ retentionMs: 7200000
+ segmentBytes: 1073741824
+
kafkaUser:
authenticationType: scram-sha-512
acls:
- name: ncmp-dmi-plugin-group
type: group
operations: [Read]
- - name: ncmp-dmi-cm-avc-subscription-ncmp-dmi-plugin
+ - name: *ncmpDmiCmAvcSubscriptionNcmpDmiPluginTopic
type: topic
operations: [Read]
- - name: dmi-ncmp-cm-avc-subscription
+ - name: *dmiNcmpCmAvcSubscriptionTopic
type: topic
operations: [Write]
- - name: ncmp-async-m2m
+ - name: *ncmpAsyncM2MTopic
type: topic
operations: [Write]
+
+topics:
+ config:
+ app.ncmp.async.topic: *ncmpAsyncM2MTopic
+ app.dmi.avc.subscription-topic: *ncmpDmiCmAvcSubscriptionNcmpDmiPluginTopic
+ app.dmi.avc.subscription-response-topic: *dmiNcmpCmAvcSubscriptionTopic