From 425ebb15f5177f99103198aedc158b5691763fd9 Mon Sep 17 00:00:00 2001 From: efiacor Date: Fri, 12 Aug 2022 13:14:17 +0100 Subject: [KAFKA] Allow kafka params to be passed as config Allow topic names to be passed Add new api endpoint to retrieve the kafka and topic info Signed-off-by: efiacor Issue-ID: DMAAP-1744 Change-Id: Id7bdcf54c6191a5953bc94092218595bf608a733 --- .../default/BE-distribution-engine-configuration.yaml.erb | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'catalog-be/src/main/docker') diff --git a/catalog-be/src/main/docker/backend/chef-repo/cookbooks/sdc-catalog-be/templates/default/BE-distribution-engine-configuration.yaml.erb b/catalog-be/src/main/docker/backend/chef-repo/cookbooks/sdc-catalog-be/templates/default/BE-distribution-engine-configuration.yaml.erb index 7eeb7a8ff8..0989def1f9 100644 --- a/catalog-be/src/main/docker/backend/chef-repo/cookbooks/sdc-catalog-be/templates/default/BE-distribution-engine-configuration.yaml.erb +++ b/catalog-be/src/main/docker/backend/chef-repo/cookbooks/sdc-catalog-be/templates/default/BE-distribution-engine-configuration.yaml.erb @@ -6,8 +6,19 @@ uebServers: uebPublicKey: <%= node['UEB']['PublicKey'] %> uebSecretKey: <%= node['UEB']['SecretKey'] %> +<% if node.exist?('DistributionTopics','notificationTopicName') -%> +distributionNotifTopicName: <%= node['DistributionTopics']['notificationTopicName'] %> +<% else %> distributionNotifTopicName: SDC-DISTR-NOTIF-TOPIC +<% end -%> + +<% if node.exist?('DistributionTopics','statusTopicName') -%> +distributionStatusTopicName: <%= node['DistributionTopics']['statusTopicName'] %> +<% else %> distributionStatusTopicName: SDC-DISTR-STATUS-TOPIC +<% end -%> + +kafkaBootStrapServers: <%= node['Kafka']['bootstrap'] %> initRetryIntervalSec: 5 initMaxIntervalSec: 60 -- cgit 1.2.3-korg