From 3b11f334df61e239c2a3e14b28afd0dc0e55153b Mon Sep 17 00:00:00 2001 From: "adheli.tavares" Date: Fri, 30 Aug 2024 10:03:26 +0100 Subject: [PATCH] Allow topics to have extra kafka configuration properties Issue-ID: POLICY-5120 Change-Id: I63378fc48601e21c551ec517aac6bd1b9ceac336 Signed-off-by: adheli.tavares --- .../src/main/feature/config/feature-legacy-config.properties | 3 ++- feature-lifecycle/src/main/feature/config/feature-lifecycle.properties | 2 ++ .../src/main/feature/config/feature-pooling-messages.properties | 2 ++ 3 files changed, 6 insertions(+), 1 deletion(-) 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 9cb73c58..087f40c9 100644 --- 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 4a60650c..45dfabdd 100644 --- 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 3870ede1..020df961 100644 --- 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} -- 2.16.6