fix: split consumer group for kafka connect worker v. connector (#744)

utilitywarehouse · Dec 20, 2024 · 79bcf9b · 79bcf9b
1 parent d7a2f07
commit 79bcf9b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/dev-aws/kafka-shared-msk/account-identity/kafka-connect.tf b/dev-aws/kafka-shared-msk/account-identity/kafka-connect.tf
@@ -1,6 +1,6 @@
 module "kafka_connect_read_legacy_account_events" {
   source           = "../../../modules/tls-app"
   consume_topics   = ["account-identity.legacy.account.events"]
-  consume_groups   = ["dev-enablement.kafka-connect-group"]
+  consume_groups   = ["dev-enablement.kafka-connect-consumer-group"]
   cert_common_name = "dev-enablement/kafka-connect"
 }
diff --git a/dev-aws/kafka-shared-msk/customer-proposition/kafka-connect.tf b/dev-aws/kafka-shared-msk/customer-proposition/kafka-connect.tf
@@ -1,6 +1,6 @@
 module "kafka_connect_read_service_status_events" {
   source           = "../../../modules/tls-app"
   consume_topics   = ["customer-proposition.service-status.events.v3"]
-  consume_groups   = ["dev-enablement.kafka-connect-group"]
+  consume_groups   = ["dev-enablement.kafka-connect-consumer-group"]
   cert_common_name = "dev-enablement/kafka-connect"
 }
diff --git a/dev-aws/kafka-shared-msk/dev-enablement/kafka-connect.tf b/dev-aws/kafka-shared-msk/dev-enablement/kafka-connect.tf
@@ -43,7 +43,7 @@ module "kafka_connect_full_internal_topics" {
   source           = "../../../modules/tls-app"
   consume_topics   = ["dev-enablement.connect-configs", "dev-enablement.connect-offsets", "dev-enablement.connect-status"]
   produce_topics   = ["dev-enablement.connect-configs", "dev-enablement.connect-offsets", "dev-enablement.connect-status"]
-  consume_groups   = ["dev-enablement.kafka-connect-group"]
+  consume_groups   = ["dev-enablement.kafka-connect-group", "dev-enablement.kafka-connect-worker-group"]
   cert_common_name = "dev-enablement/kafka-connect"
 }