From 202844a06088e8251192225a4dd75c1aa3e90ffc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81lvaro=20Mart=C3=ADn=20Gordillo?= Date: Thu, 14 Nov 2024 10:06:45 +0100 Subject: [PATCH] add missing dsar producers and consumers (#698) --- .../contact-channels/contact-channels.tf | 23 +++++++++++++++++++ .../contact-channels/contact-channels.tf | 23 +++++++++++++++++++ 2 files changed, 46 insertions(+) diff --git a/dev-aws/kafka-shared-msk/contact-channels/contact-channels.tf b/dev-aws/kafka-shared-msk/contact-channels/contact-channels.tf index 6a028ae4..0c68b816 100644 --- a/dev-aws/kafka-shared-msk/contact-channels/contact-channels.tf +++ b/dev-aws/kafka-shared-msk/contact-channels/contact-channels.tf @@ -388,3 +388,26 @@ module "dsar_request_consumer" { consume_topics = [kafka_topic.dsar.name] consume_groups = ["contact-channels.dsar-request-consumer"] } + +# Produce to contact-channels.dsar-jobs and conversations +module "dsar_job_request_producer" { + source = "../../../modules/tls-app" + cert_common_name = "contact-channels/dsar-job-runner" + produce_topics = [kafka_topic.dsar_job.name, kafka_topic.dsar_conversation.name] +} + +# Consume from contact-channels.dsar-conversations +module "dsar_conversations_retriever" { + source = "../../../modules/tls-app" + cert_common_name = "contact-channels/dsar-conversations-retriever" + consume_topics = [kafka_topic.dsar_conversation.name] + consume_groups = ["contact-channels.dsar-conversations-retriever"] +} + +# Consume from contact-channels.dsar-jobs +module "dsar_job_fulfiller" { + source = "../../../modules/tls-app" + cert_common_name = "contact-channels/dsar-job-fulfiller" + consume_topics = [kafka_topic.dsar_job.name] + consume_groups = ["contact-channels.dsar-job-fulfiller"] +} diff --git a/prod-aws/kafka-shared-msk/contact-channels/contact-channels.tf b/prod-aws/kafka-shared-msk/contact-channels/contact-channels.tf index 6a028ae4..0c68b816 100644 --- a/prod-aws/kafka-shared-msk/contact-channels/contact-channels.tf +++ b/prod-aws/kafka-shared-msk/contact-channels/contact-channels.tf @@ -388,3 +388,26 @@ module "dsar_request_consumer" { consume_topics = [kafka_topic.dsar.name] consume_groups = ["contact-channels.dsar-request-consumer"] } + +# Produce to contact-channels.dsar-jobs and conversations +module "dsar_job_request_producer" { + source = "../../../modules/tls-app" + cert_common_name = "contact-channels/dsar-job-runner" + produce_topics = [kafka_topic.dsar_job.name, kafka_topic.dsar_conversation.name] +} + +# Consume from contact-channels.dsar-conversations +module "dsar_conversations_retriever" { + source = "../../../modules/tls-app" + cert_common_name = "contact-channels/dsar-conversations-retriever" + consume_topics = [kafka_topic.dsar_conversation.name] + consume_groups = ["contact-channels.dsar-conversations-retriever"] +} + +# Consume from contact-channels.dsar-jobs +module "dsar_job_fulfiller" { + source = "../../../modules/tls-app" + cert_common_name = "contact-channels/dsar-job-fulfiller" + consume_topics = [kafka_topic.dsar_job.name] + consume_groups = ["contact-channels.dsar-job-fulfiller"] +}