diff --git a/dev-aws/kafka-shared-msk/account-identity/verification.tf b/dev-aws/kafka-shared-msk/account-identity/verification.tf
index 4a60dea6..986bfc12 100644
--- a/dev-aws/kafka-shared-msk/account-identity/verification.tf
+++ b/dev-aws/kafka-shared-msk/account-identity/verification.tf
@@ -18,6 +18,13 @@ module "account_identity_verification_indexer" {
   cert_common_name = "auth-customer/ai-verification-events-v1-indexer"
 }
 
+module "account_identity_di_kafka_source_verification" {
+  source           = "../../../modules/tls-app"
+  consume_topics   = [(kafka_topic.account_identity_verification.name)]
+  consume_groups   = ["account-identity.di-kafka-source-verification"]
+  cert_common_name = "auth-customer/di-verification"
+}
+
 resource "kafka_topic" "account_identity_verification" {
   config = {
     "cleanup.policy"   = "delete"
diff --git a/prod-aws/kafka-shared-msk/account-identity/verification.tf b/prod-aws/kafka-shared-msk/account-identity/verification.tf
index 4a60dea6..986bfc12 100644
--- a/prod-aws/kafka-shared-msk/account-identity/verification.tf
+++ b/prod-aws/kafka-shared-msk/account-identity/verification.tf
@@ -18,6 +18,13 @@ module "account_identity_verification_indexer" {
   cert_common_name = "auth-customer/ai-verification-events-v1-indexer"
 }
 
+module "account_identity_di_kafka_source_verification" {
+  source           = "../../../modules/tls-app"
+  consume_topics   = [(kafka_topic.account_identity_verification.name)]
+  consume_groups   = ["account-identity.di-kafka-source-verification"]
+  cert_common_name = "auth-customer/di-verification"
+}
+
 resource "kafka_topic" "account_identity_verification" {
   config = {
     "cleanup.policy"   = "delete"