From 79bcf9b5e87f4e0d9984939d5cd848201318d9c9 Mon Sep 17 00:00:00 2001 From: Filmon Daniels Date: Fri, 20 Dec 2024 20:00:36 +0000 Subject: [PATCH] fix: split consumer group for kafka connect worker v. connector (#744) --- dev-aws/kafka-shared-msk/account-identity/kafka-connect.tf | 2 +- dev-aws/kafka-shared-msk/customer-proposition/kafka-connect.tf | 2 +- dev-aws/kafka-shared-msk/dev-enablement/kafka-connect.tf | 2 +- 3 files changed, 3 insertions(+), 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 index 05155769..0f644844 100644 --- 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" } \ No newline at end of file diff --git a/dev-aws/kafka-shared-msk/customer-proposition/kafka-connect.tf b/dev-aws/kafka-shared-msk/customer-proposition/kafka-connect.tf index daff1f5a..96da8fcb 100644 --- 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" } \ No newline at end of file diff --git a/dev-aws/kafka-shared-msk/dev-enablement/kafka-connect.tf b/dev-aws/kafka-shared-msk/dev-enablement/kafka-connect.tf index a6be0511..eabb51b7 100644 --- 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" }