add missing dsar producers and consumers (#698)

utilitywarehouse · Nov 14, 2024 · 202844a · 202844a
1 parent 16e4437
commit 202844a
Show file tree

Hide file tree

Showing 2 changed files with 46 additions and 0 deletions.
diff --git 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
@@ -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"]
+}