account-identity: Add business validation projector consumer (#725)

In preparation for utilitywarehouse/kubernetes-manifests#101478
utilitywarehouse · Dec 12, 2024 · 1d1652f · 1d1652f
1 parent afb82bc
commit 1d1652f
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 6 deletions.
diff --git a/dev-aws/kafka-shared-msk/account-identity/account.tf b/dev-aws/kafka-shared-msk/account-identity/account.tf
@@ -120,7 +120,7 @@ resource "kafka_topic" "account_identity_to_anonymize_events" {
   replication_factor = 3
 }
 
-resource "kafka_topic" "account_identity_accunt_bill_writes_public" {
+resource "kafka_topic" "account_identity_account_bill_writes_public" {
   config = {
     "cleanup.policy" = "compact"
     # allow not compacted keys maximum for 7 days
@@ -167,6 +167,13 @@ module "account_identity_account_api_atomic_projector" {
   cert_common_name = "account-platform/account_api_atomic_projector"
 }
 
+module "account_identity_account_api_business_validation_projector" {
+  source           = "../../../modules/tls-app"
+  consume_topics   = [kafka_topic.account_identity_account_events_v2.name]
+  consume_groups   = ["account-identity.account-api-business-validation-projector"]
+  cert_common_name = "account-platform/account_api_business_validation_projector"
+}
+
 module "account_identity_account_api_change_notifier" {
   source           = "../../../modules/tls-app"
   consume_topics   = [kafka_topic.account_identity_account_atomic_v1.name]
@@ -190,14 +197,14 @@ module "account_identity_account_api_v2_dispatcher" {
 
 module "account_identity_account_api_v2" {
   source           = "../../../modules/tls-app"
-  produce_topics   = [kafka_topic.account_identity_accunt_bill_writes_public.name]
+  produce_topics   = [kafka_topic.account_identity_account_bill_writes_public.name]
   cert_common_name = "account-platform/account_api_v2"
 }
 
 
 module "account_identity_account_api_v2_customer_bill_writer" {
   source           = "../../../modules/tls-app"
-  produce_topics   = [kafka_topic.account_identity_accunt_bill_writes_public.name]
+  produce_topics   = [kafka_topic.account_identity_account_bill_writes_public.name]
   cert_common_name = "account-platform/account_api_v2_customer_bill_writer"
 }
 

diff --git a/prod-aws/kafka-shared-msk/account-identity/account.tf b/prod-aws/kafka-shared-msk/account-identity/account.tf
@@ -140,7 +140,7 @@ resource "kafka_topic" "account_identity_analytics_bill_change_events" {
   replication_factor = 3
 }
 
-resource "kafka_topic" "account_identity_accunt_bill_writes_public" {
+resource "kafka_topic" "account_identity_account_bill_writes_public" {
   config = {
     "cleanup.policy" = "compact"
     # allow not compacted keys maximum for 7 days
@@ -158,6 +158,13 @@ module "account_identity_account_api_account_atomic_producer" {
   cert_common_name = "account-platform/account_api_account_atomic_producer"
 }
 
+module "account_identity_account_api_business_validation_projector" {
+  source           = "../../../modules/tls-app"
+  consume_topics   = [kafka_topic.account_identity_account_events_v2.name]
+  consume_groups   = ["account-identity.account-api-business-validation-projector"]
+  cert_common_name = "account-platform/account_api_business_validation_projector"
+}
+
 module "account_identity_account_api_atomic_projector" {
   source           = "../../../modules/tls-app"
   consume_topics   = [kafka_topic.account_identity_account_atomic_v1.name]
@@ -191,13 +198,13 @@ module "account_identity_account_api_v2_dispatcher" {
 
 module "account_identity_account_api_v2" {
   source           = "../../../modules/tls-app"
-  produce_topics   = [kafka_topic.account_identity_accunt_bill_writes_public.name]
+  produce_topics   = [kafka_topic.account_identity_account_bill_writes_public.name]
   cert_common_name = "account-platform/account_api_v2"
 }
 
 module "account_identity_account_api_v2_customer_bill_writer" {
   source           = "../../../modules/tls-app"
-  produce_topics   = [kafka_topic.account_identity_accunt_bill_writes_public.name]
+  produce_topics   = [kafka_topic.account_identity_account_bill_writes_public.name]
   cert_common_name = "account-platform/account_api_v2_customer_bill_writer"
 }