Account exceptions processor - read creation events (#701)

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

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/dev-aws/kafka-shared-msk/account-identity/exceptions.tf b/dev-aws/kafka-shared-msk/account-identity/exceptions.tf
@@ -198,8 +198,8 @@ module "account_identity_legacy_supply_address_relay" {
 
 module "account_identity_exceptions_processor" {
   source           = "../../../modules/tls-app"
-  consume_topics   = [kafka_topic.account_identity_account_exceptions_v1.name]
-  consume_groups   = ["account-identity.account-exceptions-processor-source"]
+  consume_topics   = [kafka_topic.account_identity_account_exceptions_v1.name, kafka_topic.account_identity_account_events_v2.name]
+  consume_groups   = ["account-identity.account-exceptions-processor-source", "account-identity.account-exceptions-processor-creation-events"]
   produce_topics   = [kafka_topic.account_identity_account_exceptions_events.name]
   cert_common_name = "account-platform/exceptions_processor"
 }

diff --git a/prod-aws/kafka-shared-msk/account-identity/exceptions.tf b/prod-aws/kafka-shared-msk/account-identity/exceptions.tf
@@ -132,8 +132,8 @@ module "account_identity_land_registry_indexer" {
 
 module "account_identity_exceptions_processor" {
   source           = "../../../modules/tls-app"
-  consume_topics   = [kafka_topic.account_identity_account_exceptions_v1.name]
-  consume_groups   = ["account-identity.account-exceptions-processor-source"]
+  consume_topics   = [kafka_topic.account_identity_account_exceptions_v1.name, kafka_topic.account_identity_account_events_v2.name]
+  consume_groups   = ["account-identity.account-exceptions-processor-source", "account-identity.account-exceptions-processor-creation-events"]
   produce_topics   = [kafka_topic.account_identity_account_exceptions_events.name]
   cert_common_name = "account-platform/exceptions_processor"
 }