Skip to content

Commit

Permalink
[AP-Dev] create account_history_v1 topic (#746)
Browse files Browse the repository at this point in the history
Co-authored-by: Denis Nikulin <[email protected]>
  • Loading branch information
pansbro12 and denisnikulin authored Jan 3, 2025
1 parent 8a38435 commit 9827b2e
Showing 1 changed file with 24 additions and 0 deletions.
24 changes: 24 additions & 0 deletions dev-aws/kafka-shared-msk/account-identity/account.tf
Original file line number Diff line number Diff line change
Expand Up @@ -132,6 +132,22 @@ resource "kafka_topic" "account_identity_account_bill_writes_public" {
replication_factor = 3
}

resource "kafka_topic" "account_identity_account_history_v1" {
config = {
"cleanup.policy" = "delete"
"compression.type" = "zstd"
# keep data forever
"retention.ms" = "-1"
# enable remote storage
"remote.storage.enable" = "true"
# keep data in primary storage for 1 day
"local.retention.ms" = "86400000"
}
name = "account-identity.account.history.v1"
partitions = 15
replication_factor = 3
}

moved {
from = kafka_topic.account_identity_accunt_bill_writes_public
to = kafka_topic.account_identity_account_bill_writes_public
Expand Down Expand Up @@ -186,6 +202,14 @@ module "account_identity_account_api_change_notifier" {
cert_common_name = "account-platform/account_api_change_notifier"
}

module "account_identity_account_api_history" {
source = "../../../modules/tls-app"
consume_topics = [kafka_topic.account_identity_account_atomic_v1.name]
consume_groups = ["account-identity.account-api-history"]
produce_topics = [kafka_topic.account_identity_account_history_v1.name]
cert_common_name = "account-platform/account_api_history"
}

module "account_identity_account_v2_to_legacy" {
source = "../../../modules/tls-app"
consume_topics = [kafka_topic.account_identity_account_events_v2.name]
Expand Down

0 comments on commit 9827b2e

Please sign in to comment.