Allow topics to have extra kafka configuration properties

Issue-ID: POLICY-5120
Change-Id: I63378fc48601e21c551ec517aac6bd1b9ceac336
Signed-off-by: adheli.tavares <adheli.tavares@est.tech>

diff --git a/feature-legacy-config/src/main/feature/config/feature-legacy-config.properties b/feature-legacy-config/src/main/feature/config/feature-legacy-config.properties
index 9cb73c5..087f40c 100644 (file)
--- a/feature-legacy-config/src/main/feature/config/feature-legacy-config.properties
+++ b/feature-legacy-config/src/main/feature/config/feature-legacy-config.properties
@@ -26,4 +26,5 @@ kafka.source.topics.pdpd-configuration.apiSecret=${envd:PDPD_CONFIGURATION_API_S
 kafka.source.topics.pdpd-configuration.consumerGroup=${envd:PDPD_CONFIGURATION_CONSUMER_GROUP}
 kafka.source.topics.pdpd-configuration.consumerInstance=${envd:PDPD_CONFIGURATION_CONSUMER_INSTANCE}
 kafka.source.topics.pdpd-configuration.managed=false
-kafka.source.topics.pdpd-configuration.https=${envd:KAFKA_HTTPS:false}
+kafka.source.topics.pdpd-configuration.https=${env:KAFKA_HTTPS:false}
+kafka.source.topics.pdpd-configuration.additionalProps=${env:KAFKA_ADDITIONAL_PROPS}

diff --git a/feature-lifecycle/src/main/feature/config/feature-lifecycle.properties b/feature-lifecycle/src/main/feature/config/feature-lifecycle.properties
index 4a60650..45dfabd 100644 (file)
--- a/feature-lifecycle/src/main/feature/config/feature-lifecycle.properties
+++ b/feature-lifecycle/src/main/feature/config/feature-lifecycle.properties
@@ -31,9 +31,11 @@ kafka.source.topics.policy-pdp-pap.effectiveTopic=${envd:POLICY_PDP_PAP_TOPIC}
 kafka.source.topics.policy-pdp-pap.apiKey=${envd:POLICY_PDP_PAP_API_KEY}
 kafka.source.topics.policy-pdp-pap.apiSecret=${envd:POLICY_PDP_PAP_API_SECRET}
 kafka.source.topics.policy-pdp-pap.https=${envd:KAFKA_HTTPS:false}
+kafka.source.topics.policy-pdp-pap.additionalProps=${env:KAFKA_ADDITIONAL_PROPS}
 
 kafka.sink.topics.policy-pdp-pap.servers=${envd:KAFKA_SERVERS}
 kafka.sink.topics.policy-pdp-pap.effectiveTopic=${envd:POLICY_PDP_PAP_TOPIC}
 kafka.sink.topics.policy-pdp-pap.apiKey=${envd:POLICY_PDP_PAP_API_KEY}
 kafka.sink.topics.policy-pdp-pap.apiSecret=${envd:POLICY_PDP_PAP_API_SECRET}
 kafka.sink.topics.policy-pdp-pap.https=${envd:KAFKA_HTTPS:false}
+kafka.sink.topics.policy-pdp-pap.additionalProps=${env:KAFKA_ADDITIONAL_PROPS}

diff --git a/feature-pooling-messages/src/main/feature/config/feature-pooling-messages.properties b/feature-pooling-messages/src/main/feature/config/feature-pooling-messages.properties
index 3870ede..020df96 100644 (file)
--- a/feature-pooling-messages/src/main/feature/config/feature-pooling-messages.properties
+++ b/feature-pooling-messages/src/main/feature/config/feature-pooling-messages.properties
@@ -82,8 +82,10 @@ kafka.source.topics.policy-pdp-pooling.servers=${env:KAFKA_SERVERS}
 kafka.source.topics.policy-pdp-pooling.effectiveTopic=${env:POOLING_TOPIC}
 kafka.source.topics.policy-pdp-pooling.apiKey=
 kafka.source.topics.policy-pdp-pooling.apiSecret=
+kafka.source.topics.policy-pdp-pooling.additionalProps=${env:KAFKA_ADDITIONAL_PROPS}
 
 kafka.sink.topics.policy-pdp-pooling.servers=${env:KAFKA_SERVERS}
 kafka.sink.topics.policy-pdp-pooling.effectiveTopic=${env:POOLING_TOPIC}
 kafka.sink.topics.policy-pdp-pooling.apiKey=
 kafka.sink.topics.policy-pdp-pooling.apiSecret=
+kafka.sink.topics.policy-pdp-pooling.additionalProps=${env:KAFKA_ADDITIONAL_PROPS}