Add message-router dependency in blueprint-processor for kafka-listener. 18/93218/1
authorPrathamesh Morde <prathamesh.morde@bell.ca>
Mon, 24 Jun 2019 14:36:15 +0000 (10:36 -0400)
committerYuriy Malakov <Yuriy.Malakov@att.com>
Fri, 9 Aug 2019 13:03:00 +0000 (13:03 +0000)
Issue-ID: CCSDK-1432
Signed-off-by: Prathamesh Morde <prathamesh.morde@bell.ca>
Change-Id: I64349580b66979285857951ea6d6f18015ef63f5
Signed-off-by: Prathamesh Morde <prathamesh.morde@bell.ca>
Signed-off-by: Prathamesh Morde <prathamesh_morde@yahoo.ca>
(cherry picked from commit 93da127349566d0ba8658f4bb1d12dbe5c791a59)

kubernetes/cds/charts/cds-blueprints-processor/resources/config/application.properties
kubernetes/cds/charts/cds-blueprints-processor/templates/deployment.yaml
kubernetes/cds/charts/cds-blueprints-processor/values.yaml

index 1317300..f628e28 100755 (executable)
@@ -71,3 +71,15 @@ blueprintsprocessor.restclient.primary-aai-data.url=https://aai.onap:8443
 blueprintsprocessor.restclient.primary-aai-data.username=aai@aai.onap.org
 blueprintsprocessor.restclient.primary-aai-data.password=demo123456!
 
+# Kafka-message-lib Configuration
+blueprintsprocessor.messageclient.self-service-api.topic=cds-producer
+blueprintsprocessor.messageclient.self-service-api.type=kafka-basic-auth
+
+##ONAP Message Router Kafka Service##
+blueprintsprocessor.messageclient.self-service-api.bootstrapServers=message-router-kafka:9092
+
+blueprintsprocessor.messageclient.self-service-api.consumerTopic=cds-consumer
+blueprintsprocessor.messageclient.self-service-api.groupId=cds-consumer-group
+blueprintsprocessor.messageclient.self-service-api.clientId=cds-client
+blueprintsprocessor.messageclient.self-service-api.kafkaEnable=false
+
index 95069fc..d4c106b 100755 (executable)
@@ -36,6 +36,10 @@ spec:
         args:
         - --container-name
         - cds-db
+        {{- if .Values.dmaapEnabled  }}
+        - --container-name
+        - message-router
+        {{ end }}
         env:
         - name: NAMESPACE
           valueFrom:
index 01c629e..cf1b3d4 100755 (executable)
@@ -57,6 +57,10 @@ nodeSelector: {}
 
 affinity: {}
 
+# flag for kafka-listener dependency. Set to true if you are using message-router otherwise set to false if you are using
+# custom kafka cluster.
+dmaapEnabled: true
+
 # probe configuration parameters
 liveness:
   initialDelaySeconds: 120
@@ -82,7 +86,6 @@ service:
     internalPort: 9111
     externalPort: 9111
 
-
 persistence:
   volumeReclaimPolicy: Retain
   accessMode: ReadWriteMany