Add kafka support on drools-pdp

Issue-ID: POLICY-4201
Signed-off-by: zrrmmua <ramesh.murugan.iyer@est.tech>
Change-Id: I7f9ebec13cc41c214a400087f99e62bbc895abdd

1 files changed, 6 insertions, 0 deletions

diff --git a/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java b/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java
index 5491eac7..0c732246 100644
--- a/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java
+++ b/policy-management/src/main/java/org/onap/policy/drools/controller/IndexedDroolsControllerFactory.java
@@ -271,6 +271,12 @@ class IndexedDroolsControllerFactory implements DroolsControllerFactory {
             } else {
                 return PolicyEndPointProperties.PROPERTY_NOOP_SINK_TOPICS + ".";
             }
+        } else if (commInfra == CommInfrastructure.KAFKA) {
+            if (isSource) {
+                return PolicyEndPointProperties.PROPERTY_KAFKA_SOURCE_TOPICS + ".";
+            } else {
+                return PolicyEndPointProperties.PROPERTY_KAFKA_SINK_TOPICS + ".";
+            }
         } else {
             throw new IllegalArgumentException("Invalid Communication Infrastructure: " + commInfra);
         }