summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorrameshiyer27 <ramesh.murugan.iyer@est.tech>2023-12-04 14:16:46 +0000
committerrameshiyer27 <ramesh.murugan.iyer@est.tech>2023-12-14 11:33:50 +0000
commit5fb9f40251c402af39ec6a131d6b94b56309accd (patch)
tree79f615d3bcc1a7ffca438caad45be74444dedd07
parent3eb06ddaa6ce77b36312cf13e53b76d215ceb2cd (diff)
Add kafka suppport on drools-apps
Issue-ID: POLICY-4201 Signed-off-by: zrrmmua <ramesh.murugan.iyer@est.tech> Change-Id: I67f0ce208af5c9431d31448549b1d7d9e1272ba9
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-RSP-topic.properties6
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-topic.properties6
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-CL-topic.properties11
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-READ-topic.properties7
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-WRITE-topic.properties7
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_CL_RSP-topic.properties6
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_TOPIC-topic.properties8
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/POLICY-CL-MGT-topic.properties5
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-RSP-topic.properties6
-rw-r--r--controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-topic.properties8
10 files changed, 70 insertions, 0 deletions
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-RSP-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-RSP-topic.properties
index adf2b23a4..8e9d2dcab 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-RSP-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-RSP-topic.properties
@@ -16,6 +16,12 @@
# limitations under the License.
# ============LICENSE_END=========================================================
+
dmaap.source.topics=A1-P-RSP
dmaap.source.topics.A1-P-RSP.servers=${envd:DMAAP_SERVERS}
dmaap.source.topics.A1-P-RSP.https=${envd:DMAAP_HTTPS:true}
+
+#Replace the properties with the following to use kafka message broker
+#kafka.source.topics=a1-p-rsp
+#kafka.source.topics.a1-p-rsp.servers=${envd:DMAAP_SERVERS}
+#kafka.source.topics.a1-p-rsp.https=${envd:DMAAP_HTTPS:true}
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-topic.properties
index 646d5a08a..26591baf0 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/A1-P-topic.properties
@@ -21,3 +21,9 @@ dmaap.sink.topics=A1-P
dmaap.sink.topics.A1-P.servers=${envd:DMAAP_SERVERS}
dmaap.sink.topics.A1-P.https=${envd:DMAAP_HTTPS:true}
+#Replace the properties with the following to use kafka message broker
+#kafka.sink.topics=a1-p
+
+#kafka.sink.topics.A1-P.servers=${envd:DMAAP_SERVERS}
+#kafka.sink.topics.A1-P.https=${envd:DMAAP_HTTPS:true}
+
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-CL-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-CL-topic.properties
index d8260be27..f5b7c158c 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-CL-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-CL-topic.properties
@@ -16,6 +16,7 @@
# limitations under the License.
# ============LICENSE_END=========================================================
+
dmaap.source.topics=APPC-CL
dmaap.sink.topics=APPC-CL
@@ -24,3 +25,13 @@ dmaap.source.topics.APPC-CL.https=${envd:DMAAP_HTTPS:true}
dmaap.sink.topics.APPC-CL.servers=${envd:DMAAP_SERVERS}
dmaap.sink.topics.APPC-CL.https=${envd:DMAAP_HTTPS:true}
+
+#Replace the properties with the following to use kafka message broker
+#kafka.source.topics=appc-cl
+#kafka.sink.topics=appc-cl
+
+#kafka.source.topics.appc-cl.servers=${envd:DMAAP_SERVERS}
+#kafka.source.topics.appc-cl.https=${envd:DMAAP_HTTPS:true}
+
+#kafka.sink.topics.appc-cl.servers=${envd:DMAAP_SERVERS}
+#kafka.sink.topics.appc-cl.https=${envd:DMAAP_HTTPS:true}
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-READ-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-READ-topic.properties
index fc088d742..f50958f0e 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-READ-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-READ-topic.properties
@@ -16,8 +16,15 @@
# limitations under the License.
# ============LICENSE_END=========================================================
+
dmaap.sink.topics=APPC-LCM-READ
dmaap.sink.topics.APPC-LCM-READ.servers=${envd:DMAAP_SERVERS}
dmaap.sink.topics.APPC-LCM-READ.https=${envd:DMAAP_HTTPS:true}
+#Replace the properties with the following to use kafka message broker
+#kafka.sink.topics=appc-lcm-read
+
+#kafka.sink.topics.appc-lcm-read.servers=${envd:DMAAP_SERVERS}
+#kafka.sink.topics.appc-lcm-read.https=${envd:DMAAP_HTTPS:true}
+
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-WRITE-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-WRITE-topic.properties
index afcf207d2..414c3a2e8 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-WRITE-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/APPC-LCM-WRITE-topic.properties
@@ -16,7 +16,14 @@
# limitations under the License.
# ============LICENSE_END=========================================================
+
dmaap.source.topics=APPC-LCM-WRITE
dmaap.source.topics.APPC-LCM-WRITE.servers=${envd:DMAAP_SERVERS}
dmaap.source.topics.APPC-LCM-WRITE.https=${envd:DMAAP_HTTPS:true}
+
+#Replace the properties with the following to use kafka message broker
+#kafka.source.topics=appc-lcm-write
+
+#kafka.source.topics.appc-lcm-write.servers=${envd:DMAAP_SERVERS}
+#kafka.source.topics.appc-lcm-write.https=${envd:DMAAP_HTTPS:true}
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_CL_RSP-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_CL_RSP-topic.properties
index 01b091557..54ce1aaa7 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_CL_RSP-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_CL_RSP-topic.properties
@@ -21,3 +21,9 @@ dmaap.sink.topics=DCAE_CL_RSP
dmaap.sink.topics.DCAE_CL_RSP.servers=${env:DMAAP_SERVERS}
dmaap.sink.topics.DCAE_CL_RSP.https=${envd:DMAAP_HTTPS:true}
+
+#Replace the properties with the following to use kafka message broker
+#kafka.sink.topics=dcae-cl-rsp
+
+#kafka.sink.topics.dcae-cl-rsp.servers=${env:DMAAP_SERVERS}
+#kafka.sink.topics.dcae-cl-rsp.https=${envd:DMAAP_HTTPS:true}
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_TOPIC-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_TOPIC-topic.properties
index 9fe004791..d444df859 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_TOPIC-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/DCAE_TOPIC-topic.properties
@@ -22,3 +22,11 @@ dmaap.source.topics.DCAE_TOPIC.effectiveTopic=${envd:DCAE_TOPIC}
dmaap.source.topics.DCAE_TOPIC.servers=${envd:DMAAP_SERVERS}
dmaap.source.topics.DCAE_TOPIC.consumerGroup=${envd:DCAE_CONSUMER_GROUP}
dmaap.source.topics.DCAE_TOPIC.https=${envd:DMAAP_HTTPS:true}
+
+#Replace the properties with the following to use kafka message broker
+#kafka.source.topics=dcae_topic
+
+#kafka.source.topics.dcae_topic.effectiveTopic=${envd:DCAE_TOPIC}
+#kafka.source.topics.dcae_topic.servers=${envd:DMAAP_SERVERS}
+#kafka.source.topics.dcae_topic.consumerGroup=${envd:DCAE_CONSUMER_GROUP}
+#kafka.source.topics.dcae_topic.https=${envd:DMAAP_HTTPS:true}
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/POLICY-CL-MGT-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/POLICY-CL-MGT-topic.properties
index ef5bd4997..74cf296dc 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/POLICY-CL-MGT-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/POLICY-CL-MGT-topic.properties
@@ -19,3 +19,8 @@
dmaap.sink.topics=POLICY-CL-MGT
dmaap.sink.topics.POLICY-CL-MGT.servers=${envd:DMAAP_SERVERS}
dmaap.sink.topics.POLICY-CL-MGT.https=${envd:DMAAP_HTTPS:true}
+
+#Replace the properties with the following to use kafka message broker
+#kafka.sink.topics=policy-cl-mgt
+#kafka.sink.topics.policy-cl-mgt.servers=${envd:DMAAP_SERVERS}
+#kafka.sink.topics.policy-cl-mgt.https=${envd:DMAAP_HTTPS:true}
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-RSP-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-RSP-topic.properties
index 4f5be14b9..b3b8ee297 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-RSP-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-RSP-topic.properties
@@ -16,6 +16,12 @@
# limitations under the License.
# ============LICENSE_END=========================================================
+
dmaap.source.topics=SDNR-CL-RSP
dmaap.source.topics.SDNR-CL-RSP.servers=${envd:DMAAP_SERVERS}
dmaap.source.topics.SDNR-CL-RSP.https=${envd:DMAAP_HTTPS:true}
+
+#Replace the properties with the following to use kafka message broker
+#kafka.source.topics=sdnr-cl-rsp
+#kafka.source.topics.sdnr-cl-rsp.servers=${envd:DMAAP_SERVERS}
+#kafka.source.topics.sdnr-cl-rsp.https=${envd:DMAAP_HTTPS:true}
diff --git a/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-topic.properties b/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-topic.properties
index 99b55b994..145943543 100644
--- a/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-topic.properties
+++ b/controlloop/common/feature-controlloop-management/src/main/feature/config/SDNR-CL-topic.properties
@@ -16,8 +16,16 @@
# limitations under the License.
# ============LICENSE_END=========================================================
+
+
dmaap.sink.topics=SDNR-CL
dmaap.sink.topics.SDNR-CL.servers=${envd:DMAAP_SERVERS}
dmaap.sink.topics.SDNR-CL.https=${envd:DMAAP_HTTPS:true}
+#Replace the properties with the following to use kafka message broker
+#kafka.sink.topics=sdnr-cl
+
+#kafka.sink.topics.sdnr-cl.servers=${envd:DMAAP_SERVERS}
+#kafka.sink.topics.sdnr-cl.https=${envd:DMAAP_HTTPS:true}
+