msk restore: test a broader restore with multiple topics in one go #1045
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
|
Terraform run output for ✅ Run Status: Ok, Run Summary: Plan: 38 to add, 0 to change, 0 to destroy.Terraform used the selected providers to generate the following execution
plan. Resource actions are indicated with the following symbols:
+ create
Terraform will perform the following actions:
# kafka_topic.restore_account_identity_account_exceptions_v1 will be created
+ resource "kafka_topic" "restore_account_identity_account_exceptions_v1" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.account.exceptions.v1"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_correspondence_address_debt_exception_check_events will be created
+ resource "kafka_topic" "restore_account_identity_correspondence_address_debt_exception_check_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_correspondence_address_exception_check_events will be created
+ resource "kafka_topic" "restore_account_identity_correspondence_address_exception_check_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.correspondence.address.exception.check.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_internal_legacy_account_events will be created
+ resource "kafka_topic" "restore_account_identity_internal_legacy_account_events" {
+ config = {
+ "cleanup.policy" = "compact"
+ "compression.type" = "zstd"
+ "max.compaction.lag.ms" = "604800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.internal.legacy.account.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_legacy_account_braze_events_compacted will be created
+ resource "kafka_topic" "restore_account_identity_legacy_account_braze_events_compacted" {
+ config = {
+ "cleanup.policy" = "compact"
+ "compression.type" = "zstd"
+ "max.compaction.lag.ms" = "604800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_legacy_account_events will be created
+ resource "kafka_topic" "restore_account_identity_legacy_account_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.legacy.account.events"
+ partitions = 50
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_legacy_account_holder_events_compacted will be created
+ resource "kafka_topic" "restore_account_identity_legacy_account_holder_events_compacted" {
+ config = {
+ "cleanup.policy" = "compact"
+ "compression.type" = "zstd"
+ "max.compaction.lag.ms" = "604800000"
+ "max.message.bytes" = "1048588"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_staff_okta_v6 will be created
+ resource "kafka_topic" "restore_account_identity_staff_okta_v6" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.staff.okta.v6"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_supply_address_debt_exception_check_events will be created
+ resource "kafka_topic" "restore_account_identity_supply_address_debt_exception_check_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_bill_reconciliation_error_events will be created
+ resource "kafka_topic" "restore_bill_reconciliation_error_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "2629800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.billing.bill-reconciliation-error-events"
+ partitions = 2
+ replication_factor = 3
}
# kafka_topic.restore_billing_engine_events_bce_deadletter will be created
+ resource "kafka_topic" "restore_billing_engine_events_bce_deadletter" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "2629800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.billing.billing-engine-events-bce-deadletter"
+ partitions = 2
+ replication_factor = 3
}
# kafka_topic.restore_events will be created
+ resource "kafka_topic" "restore_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_events_end will be created
+ resource "kafka_topic" "restore_events_end" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_fixed_width_file_processing_events will be created
+ resource "kafka_topic" "restore_fixed_width_file_processing_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "2629800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.billing.fixed-width-file-processing-events"
+ partitions = 2
+ replication_factor = 3
}
# kafka_topic.restore_iam_credentials_v1 will be created
+ resource "kafka_topic" "restore_iam_credentials_v1" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "104857600"
+ "retention.ms" = "604800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.auth-customer.iam-credentials-v1"
+ partitions = 10
+ replication_factor = 3
}
# kafka_topic.restore_iam_identitydb_v1 will be created
+ resource "kafka_topic" "restore_iam_identitydb_v1" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "max.message.bytes" = "5242880"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "104857600"
+ "retention.ms" = "2592000000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.auth.iam-identitydb-v1"
+ partitions = 1
+ replication_factor = 3
}
# kafka_topic.restore_service_status_deadletter_v4 will be created
+ resource "kafka_topic" "restore_service_status_deadletter_v4" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "3600000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "-1"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"
+ partitions = 1
+ replication_factor = 3
}
# kafka_topic.restore_service_status_v4 will be created
+ resource "kafka_topic" "restore_service_status_v4" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "3600000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "-1"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.customer-proposition.service-status.events.v4"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_unicom_tests will be created
+ resource "kafka_topic" "restore_unicom_tests" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "259200000"
+ "max.message.bytes" = "536870912"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "7889400000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.unicom.tests"
+ partitions = 15
+ replication_factor = 3
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.account.exceptions.v1"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.account.exceptions.v1"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.exception.check.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.correspondence.address.exception.check.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.internal.legacy.account.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.internal.legacy.account.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.legacy.account.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.staff.okta.v6"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.staff.okta.v6"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth-customer.iam-credentials-v1"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.auth-customer.iam-credentials-v1"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth.iam-identitydb-v1"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.auth.iam-identitydb-v1"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.bill-reconciliation-error-events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.billing.bill-reconciliation-error-events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.billing-engine-events-bce-deadletter"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.billing.billing-engine-events-bce-deadletter"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.fixed-width-file-processing-events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.billing.fixed-width-file-processing-events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.v4"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.customer-proposition.service-status.events.v4"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.unicom.tests"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.unicom.tests"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
Plan: 38 to add, 0 to change, 0 to destroy.
|
|
Terraform run output for ✅ Run Status: Ok, Run Summary: Plan: 0 to add, 1 to change, 0 to destroy.Terraform used the selected providers to generate the following execution
plan. Resource actions are indicated with the following symbols:
~ update in-place
Terraform will perform the following actions:
# aws_s3_bucket_lifecycle_configuration.msk_topics_retention will be updated in-place
~ resource "aws_s3_bucket_lifecycle_configuration" "msk_topics_retention" {
id = "uw-dev-pubsub-msk-backup"
# (4 unchanged attributes hidden)
~ rule {
~ id = "payment-platform.payment.v1.public.events.debt" -> "payment-platform.payment.v1.public.events.pp_test"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/payment-platform.payment.v1.public.events.debt/" -> "msk-backup-parquet/payment-platform.payment.v1.public.events.pp_test/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "payment-platform.payment.v1.public.events.pp_test" -> "payment-platform.payment.v1.public.events"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/payment-platform.payment.v1.public.events.pp_test/" -> "msk-backup-parquet/payment-platform.payment.v1.public.events/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "payment-platform.payment.v1.public.events" -> "pubsub.examples"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 31 -> 1
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/payment-platform.payment.v1.public.events/" -> "msk-backup-parquet/pubsub.examples/"
}
}
~ rule {
~ id = "pubsub.examples" -> "pubsub.proximo-example"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 1 -> 3
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/pubsub.examples/" -> "msk-backup-parquet/pubsub.proximo-example/"
}
}
~ rule {
~ id = "pubsub.proximo-example" -> "pubsub.restore-test.auth-customer.iam-credentials-v1"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 3 -> 8
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/pubsub.proximo-example/" -> "msk-backup-parquet/pubsub.restore-test.auth-customer.iam-credentials-v1/"
}
}
~ rule {
~ id = "pubsub.restore-test.energy-platform.meter.read.events.v3" -> "pubsub.restore-test.auth.iam-identitydb-v1"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/pubsub.restore-test.energy-platform.meter.read.events.v3/" -> "msk-backup-parquet/pubsub.restore-test.auth.iam-identitydb-v1/"
}
}
~ rule {
~ id = "unicom.bill-events" -> "pubsub.restore-test.billing.bill-reconciliation-error-events"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/unicom.bill-events/" -> "msk-backup-parquet/pubsub.restore-test.billing.bill-reconciliation-error-events/"
}
}
~ rule {
~ id = "unicom.bill-failed" -> "pubsub.restore-test.billing.billing-engine-events-bce-deadletter"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/unicom.bill-failed/" -> "msk-backup-parquet/pubsub.restore-test.billing.billing-engine-events-bce-deadletter/"
}
}
~ rule {
~ id = "unicom.bounce.2019.1" -> "pubsub.restore-test.billing.fixed-width-file-processing-events"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/unicom.bounce.2019.1/" -> "msk-backup-parquet/pubsub.restore-test.billing.fixed-width-file-processing-events/"
}
}
~ rule {
~ id = "unicom.cancel-status.1" -> "pubsub.restore-test.energy-platform.meter.read.events.v3"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.cancel-status.1/" -> "msk-backup-parquet/pubsub.restore-test.energy-platform.meter.read.events.v3/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.cancellation.1" -> "pubsub.restore-test.unicom.tests"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.cancellation.1/" -> "msk-backup-parquet/pubsub.restore-test.unicom.tests/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.caps-consent" -> "unicom.bill-events"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.caps-consent/" -> "msk-backup-parquet/unicom.bill-events/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.caps" -> "unicom.bill-failed"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.caps/" -> "msk-backup-parquet/unicom.bill-failed/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.clx-report" -> "unicom.bounce.2019.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.clx-report/" -> "msk-backup-parquet/unicom.bounce.2019.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.comms-fallback.1" -> "unicom.cancel-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.comms-fallback.1/" -> "msk-backup-parquet/unicom.cancel-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.cost-calculated.1" -> "unicom.cancellation.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.cost-calculated.1/" -> "msk-backup-parquet/unicom.cancellation.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-batch.1" -> "unicom.caps-consent"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-batch.1/" -> "msk-backup-parquet/unicom.caps-consent/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-post-delivery.1" -> "unicom.caps"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-post-delivery.1/" -> "msk-backup-parquet/unicom.caps/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-critical.1" -> "unicom.clx-report"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-critical.1/" -> "msk-backup-parquet/unicom.clx-report/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-important.1" -> "unicom.comms-fallback.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-important.1/" -> "msk-backup-parquet/unicom.comms-fallback.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-mock-critical.1" -> "unicom.cost-calculated.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-mock-critical.1/" -> "msk-backup-parquet/unicom.cost-calculated.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-mock-important.1" -> "unicom.email-batch.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-mock-important.1/" -> "msk-backup-parquet/unicom.email-batch.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-mock.1" -> "unicom.email-post-delivery.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-mock.1/" -> "msk-backup-parquet/unicom.email-post-delivery.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-ses-critical.1" -> "unicom.email-released-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-ses-critical.1/" -> "msk-backup-parquet/unicom.email-released-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-ses-important.1" -> "unicom.email-released-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-ses-important.1/" -> "msk-backup-parquet/unicom.email-released-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-ses.1" -> "unicom.email-released-mock-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-ses.1/" -> "msk-backup-parquet/unicom.email-released-mock-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released.1" -> "unicom.email-released-mock-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released.1/" -> "msk-backup-parquet/unicom.email-released-mock-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-status.1" -> "unicom.email-released-mock.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-status.1/" -> "msk-backup-parquet/unicom.email-released-mock.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.failed" -> "unicom.email-released-ses-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.failed/" -> "msk-backup-parquet/unicom.email-released-ses-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.go-inspire-letter-status.1" -> "unicom.email-released-ses-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.go-inspire-letter-status.1/" -> "msk-backup-parquet/unicom.email-released-ses-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-batch-critical.1" -> "unicom.email-released-ses.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-batch-critical.1/" -> "msk-backup-parquet/unicom.email-released-ses.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-batch-important.1" -> "unicom.email-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-batch-important.1/" -> "msk-backup-parquet/unicom.email-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-batch.1" -> "unicom.email-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-batch.1/" -> "msk-backup-parquet/unicom.email-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-critical.1" -> "unicom.failed"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-critical.1/" -> "msk-backup-parquet/unicom.failed/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-important.1" -> "unicom.go-inspire-letter-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-important.1/" -> "msk-backup-parquet/unicom.go-inspire-letter-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-mock-critical.1" -> "unicom.letter-batch-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-mock-critical.1/" -> "msk-backup-parquet/unicom.letter-batch-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-mock-important.1" -> "unicom.letter-batch-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-mock-important.1/" -> "msk-backup-parquet/unicom.letter-batch-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-mock.1" -> "unicom.letter-batch.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-mock.1/" -> "msk-backup-parquet/unicom.letter-batch.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released.1" -> "unicom.letter-released-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released.1/" -> "msk-backup-parquet/unicom.letter-released-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-send-adare" -> "unicom.letter-released-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-send-adare/" -> "msk-backup-parquet/unicom.letter-released-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-status.1" -> "unicom.letter-released-mock-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-status.1/" -> "msk-backup-parquet/unicom.letter-released-mock-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.mparticle-output-integration" -> "unicom.letter-released-mock-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.mparticle-output-integration/" -> "msk-backup-parquet/unicom.letter-released-mock-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.orchestration-entity.1" -> "unicom.letter-released-mock.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.orchestration-entity.1/" -> "msk-backup-parquet/unicom.letter-released-mock.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.orchestration-rule-execution.1" -> "unicom.letter-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.orchestration-rule-execution.1/" -> "msk-backup-parquet/unicom.letter-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.outbound-call-request" -> "unicom.letter-send-adare"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.outbound-call-request/" -> "msk-backup-parquet/unicom.letter-send-adare/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.push-notification-released.1" -> "unicom.letter-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.push-notification-released.1/" -> "msk-backup-parquet/unicom.letter-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.push-notification-status.1" -> "unicom.mparticle-output-integration"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.push-notification-status.1/" -> "msk-backup-parquet/unicom.mparticle-output-integration/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.rejected" -> "unicom.orchestration-entity.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.rejected/" -> "msk-backup-parquet/unicom.orchestration-entity.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.rendered.1" -> "unicom.orchestration-rule-execution.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.rendered.1/" -> "msk-backup-parquet/unicom.orchestration-rule-execution.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.requests" -> "unicom.outbound-call-request"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.requests/" -> "msk-backup-parquet/unicom.outbound-call-request/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.scheduled.1" -> "unicom.push-notification-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.scheduled.1/" -> "msk-backup-parquet/unicom.push-notification-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.send-notification.1" -> "unicom.push-notification-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.send-notification.1/" -> "msk-backup-parquet/unicom.push-notification-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sftp-status" -> "unicom.rejected"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sftp-status/" -> "msk-backup-parquet/unicom.rejected/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-batch.1" -> "unicom.rendered.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-batch.1/" -> "msk-backup-parquet/unicom.rendered.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-released-critical.1" -> "unicom.requests"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-released-critical.1/" -> "msk-backup-parquet/unicom.requests/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-released-important.1" -> "unicom.scheduled.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-released-important.1/" -> "msk-backup-parquet/unicom.scheduled.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-released.1" -> "unicom.send-notification.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-released.1/" -> "msk-backup-parquet/unicom.send-notification.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-status.1" -> "unicom.sftp-status"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-status.1/" -> "msk-backup-parquet/unicom.sftp-status/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-bill-email-connector" -> "unicom.sms-batch.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-bill-email-connector/" -> "msk-backup-parquet/unicom.sms-batch.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-energy-smets1-notifier" -> "unicom.sms-released-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-energy-smets1-notifier/" -> "msk-backup-parquet/unicom.sms-released-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-finance-email-delivery-engine" -> "unicom.sms-released-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-finance-email-delivery-engine/" -> "msk-backup-parquet/unicom.sms-released-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-v2" -> "unicom.sms-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-v2/" -> "msk-backup-parquet/unicom.sms-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status" -> "unicom.sms-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status/" -> "msk-backup-parquet/unicom.sms-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.tests" -> "unicom.status-bill-email-connector"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.tests/" -> "msk-backup-parquet/unicom.status-bill-email-connector/"
}
# (1 unchanged block hidden)
}
+ rule {
+ id = "unicom.status-energy-smets1-notifier"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status-energy-smets1-notifier/"
}
}
+ rule {
+ id = "unicom.status-finance-email-delivery-engine"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status-finance-email-delivery-engine/"
}
}
+ rule {
+ id = "unicom.status-v2"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status-v2/"
}
}
+ rule {
+ id = "unicom.status"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status/"
}
}
+ rule {
+ id = "unicom.tests"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.tests/"
}
}
# (121 unchanged blocks hidden)
}
Plan: 0 to add, 1 to change, 0 to destroy.
|
hectorhuertas
approved these changes
Oct 29, 2025
hectorhuertas
approved these changes
Oct 29, 2025
DTLP
approved these changes
Oct 29, 2025
|
Terraform run output for ✅ Run Status: Ok, Run Summary: Apply complete! Resources: 38 added, 0 changed, 0 destroyedTerraform used the selected providers to generate the following execution
plan. Resource actions are indicated with the following symbols:
+ create
Terraform will perform the following actions:
# kafka_topic.restore_account_identity_account_exceptions_v1 will be created
+ resource "kafka_topic" "restore_account_identity_account_exceptions_v1" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.account.exceptions.v1"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_correspondence_address_debt_exception_check_events will be created
+ resource "kafka_topic" "restore_account_identity_correspondence_address_debt_exception_check_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_correspondence_address_exception_check_events will be created
+ resource "kafka_topic" "restore_account_identity_correspondence_address_exception_check_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.correspondence.address.exception.check.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_internal_legacy_account_events will be created
+ resource "kafka_topic" "restore_account_identity_internal_legacy_account_events" {
+ config = {
+ "cleanup.policy" = "compact"
+ "compression.type" = "zstd"
+ "max.compaction.lag.ms" = "604800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.internal.legacy.account.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_legacy_account_braze_events_compacted will be created
+ resource "kafka_topic" "restore_account_identity_legacy_account_braze_events_compacted" {
+ config = {
+ "cleanup.policy" = "compact"
+ "compression.type" = "zstd"
+ "max.compaction.lag.ms" = "604800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_legacy_account_events will be created
+ resource "kafka_topic" "restore_account_identity_legacy_account_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.legacy.account.events"
+ partitions = 50
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_legacy_account_holder_events_compacted will be created
+ resource "kafka_topic" "restore_account_identity_legacy_account_holder_events_compacted" {
+ config = {
+ "cleanup.policy" = "compact"
+ "compression.type" = "zstd"
+ "max.compaction.lag.ms" = "604800000"
+ "max.message.bytes" = "1048588"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_staff_okta_v6 will be created
+ resource "kafka_topic" "restore_account_identity_staff_okta_v6" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.staff.okta.v6"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_account_identity_supply_address_debt_exception_check_events will be created
+ resource "kafka_topic" "restore_account_identity_supply_address_debt_exception_check_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_bill_reconciliation_error_events will be created
+ resource "kafka_topic" "restore_bill_reconciliation_error_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "2629800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.billing.bill-reconciliation-error-events"
+ partitions = 2
+ replication_factor = 3
}
# kafka_topic.restore_billing_engine_events_bce_deadletter will be created
+ resource "kafka_topic" "restore_billing_engine_events_bce_deadletter" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "2629800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.billing.billing-engine-events-bce-deadletter"
+ partitions = 2
+ replication_factor = 3
}
# kafka_topic.restore_events will be created
+ resource "kafka_topic" "restore_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_events_end will be created
+ resource "kafka_topic" "restore_events_end" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "86400000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_fixed_width_file_processing_events will be created
+ resource "kafka_topic" "restore_fixed_width_file_processing_events" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "2629800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.billing.fixed-width-file-processing-events"
+ partitions = 2
+ replication_factor = 3
}
# kafka_topic.restore_iam_credentials_v1 will be created
+ resource "kafka_topic" "restore_iam_credentials_v1" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "104857600"
+ "retention.ms" = "604800000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.auth-customer.iam-credentials-v1"
+ partitions = 10
+ replication_factor = 3
}
# kafka_topic.restore_iam_identitydb_v1 will be created
+ resource "kafka_topic" "restore_iam_identitydb_v1" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "172800000"
+ "max.message.bytes" = "5242880"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "104857600"
+ "retention.ms" = "2592000000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.auth.iam-identitydb-v1"
+ partitions = 1
+ replication_factor = 3
}
# kafka_topic.restore_service_status_deadletter_v4 will be created
+ resource "kafka_topic" "restore_service_status_deadletter_v4" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "3600000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "-1"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"
+ partitions = 1
+ replication_factor = 3
}
# kafka_topic.restore_service_status_v4 will be created
+ resource "kafka_topic" "restore_service_status_v4" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "3600000"
+ "max.message.bytes" = "1048576"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.bytes" = "-1"
+ "retention.ms" = "-1"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.customer-proposition.service-status.events.v4"
+ partitions = 15
+ replication_factor = 3
}
# kafka_topic.restore_unicom_tests will be created
+ resource "kafka_topic" "restore_unicom_tests" {
+ config = {
+ "cleanup.policy" = "delete"
+ "compression.type" = "zstd"
+ "local.retention.ms" = "259200000"
+ "max.message.bytes" = "536870912"
+ "message.timestamp.difference.max.ms" = "9223372036854775807"
+ "remote.storage.enable" = "true"
+ "retention.ms" = "7889400000"
}
+ id = (known after apply)
+ name = "pubsub.restore-test.unicom.tests"
+ partitions = 15
+ replication_factor = 3
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.account.exceptions.v1"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.account.exceptions.v1"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.exception.check.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.correspondence.address.exception.check.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.internal.legacy.account.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.internal.legacy.account.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.legacy.account.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.staff.okta.v6"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.staff.okta.v6"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth-customer.iam-credentials-v1"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.auth-customer.iam-credentials-v1"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth.iam-identitydb-v1"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.auth.iam-identitydb-v1"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.bill-reconciliation-error-events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.billing.bill-reconciliation-error-events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.billing-engine-events-bce-deadletter"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.billing.billing-engine-events-bce-deadletter"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.fixed-width-file-processing-events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.billing.fixed-width-file-processing-events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.v4"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.customer-proposition.service-status.events.v4"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
# module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.unicom.tests"] will be created
+ resource "kafka_acl" "producer_acl" {
+ acl_host = "*"
+ acl_operation = "Write"
+ acl_permission_type = "Allow"
+ acl_principal = "User:CN=pubsub/test-msk-backup-kafka-connect"
+ id = (known after apply)
+ resource_name = "pubsub.restore-test.unicom.tests"
+ resource_pattern_type_filter = "Literal"
+ resource_type = "Topic"
}
Plan: 38 to add, 0 to change, 0 to destroy.
kafka_topic.restore_account_identity_staff_okta_v6: Creating...
kafka_topic.restore_account_identity_account_exceptions_v1: Creating...
kafka_topic.restore_service_status_v4: Creating...
kafka_topic.restore_account_identity_legacy_account_braze_events_compacted: Creating...
kafka_topic.restore_account_identity_correspondence_address_exception_check_events: Creating...
kafka_topic.restore_service_status_deadletter_v4: Creating...
kafka_topic.restore_iam_identitydb_v1: Creating...
kafka_topic.restore_account_identity_correspondence_address_debt_exception_check_events: Creating...
kafka_topic.restore_unicom_tests: Creating...
kafka_topic.restore_bill_reconciliation_error_events: Creating...
kafka_topic.restore_account_identity_correspondence_address_exception_check_events: Creation complete after 1s [id=pubsub.restore-test.account-identity.correspondence.address.exception.check.events]
kafka_topic.restore_events: Creating...
kafka_topic.restore_iam_identitydb_v1: Creation complete after 1s [id=pubsub.restore-test.auth.iam-identitydb-v1]
kafka_topic.restore_account_identity_legacy_account_events: Creating...
kafka_topic.restore_account_identity_legacy_account_braze_events_compacted: Creation complete after 1s [id=pubsub.restore-test.account-identity.legacy.account.braze.events.compacted]
kafka_topic.restore_account_identity_legacy_account_holder_events_compacted: Creating...
kafka_topic.restore_bill_reconciliation_error_events: Creation complete after 2s [id=pubsub.restore-test.billing.bill-reconciliation-error-events]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth-customer.iam-credentials-v1"]: Creating...
kafka_topic.restore_service_status_deadletter_v4: Creation complete after 2s [id=pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4]
kafka_topic.restore_account_identity_account_exceptions_v1: Creation complete after 2s [id=pubsub.restore-test.account-identity.account.exceptions.v1]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"]: Creating...
kafka_topic.restore_unicom_tests: Creation complete after 2s [id=pubsub.restore-test.unicom.tests]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.billing-engine-events-bce-deadletter"]: Creating...
kafka_topic.restore_account_identity_correspondence_address_debt_exception_check_events: Creation complete after 2s [id=pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"]: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"]: Creating...
kafka_topic.restore_service_status_v4: Creation complete after 2s [id=pubsub.restore-test.customer-proposition.service-status.events.v4]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.account.exceptions.v1"]: Creating...
kafka_topic.restore_account_identity_staff_okta_v6: Creation complete after 2s [id=pubsub.restore-test.account-identity.staff.okta.v6]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.exception.check.events"]: Creating...
kafka_topic.restore_events: Creation complete after 1s [id=pubsub.restore-test.data-infra.uw.data-infra.product.v1.events]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.events"]: Creating...
kafka_topic.restore_account_identity_legacy_account_events: Creation complete after 2s [id=pubsub.restore-test.account-identity.legacy.account.events]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.bill-reconciliation-error-events"]: Creating...
kafka_topic.restore_account_identity_legacy_account_holder_events_compacted: Creation complete after 2s [id=pubsub.restore-test.account-identity.legacy.account.holder.events.compacted]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"]: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events"]: Creation complete after 0s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.correspondence.address.debt.exception.check.events|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth.iam-identitydb-v1"]: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth-customer.iam-credentials-v1"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.auth-customer.iam-credentials-v1|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"]: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.holder.events.compacted"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.legacy.account.holder.events.compacted|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.customer-proposition.service-status.events.deadletter.v4|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.events"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.data-infra.uw.data-infra.product.v1.events|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.correspondence.address.exception.check.events"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.correspondence.address.exception.check.events|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.bill-reconciliation-error-events"]: Creation complete after 0s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.billing.bill-reconciliation-error-events|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.account.exceptions.v1"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.account.exceptions.v1|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.billing-engine-events-bce-deadletter"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.billing.billing-engine-events-bce-deadletter|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.events"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.legacy.account.events|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"]: Creating...
kafka_topic.restore_iam_credentials_v1: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.internal.legacy.account.events"]: Creating...
kafka_topic.restore_account_identity_supply_address_debt_exception_check_events: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.staff.okta.v6"]: Creating...
kafka_topic.restore_fixed_width_file_processing_events: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.fixed-width-file-processing-events"]: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"]: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.internal.legacy.account.events"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.internal.legacy.account.events|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.v4"]: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.billing.fixed-width-file-processing-events"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.billing.fixed-width-file-processing-events|Literal]
kafka_topic.restore_account_identity_internal_legacy_account_events: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.supply.address.debt.exception.check.events"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.supply.address.debt.exception.check.events|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.legacy.account.braze.events.compacted"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.legacy.account.braze.events.compacted|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.account-identity.staff.okta.v6"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.account-identity.staff.okta.v6|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.auth.iam-identitydb-v1"]: Creation complete after 1s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.auth.iam-identitydb-v1|Literal]
kafka_topic.restore_events_end: Creating...
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.unicom.tests"]: Creating...
kafka_topic.restore_billing_engine_events_bce_deadletter: Creating...
kafka_topic.restore_fixed_width_file_processing_events: Creation complete after 1s [id=pubsub.restore-test.billing.fixed-width-file-processing-events]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.unicom.tests"]: Creation complete after 0s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.unicom.tests|Literal]
module.test_kafka_connect_full_internal_topics.kafka_acl.producer_acl["pubsub.restore-test.customer-proposition.service-status.events.v4"]: Creation complete after 0s [id=User:CN=pubsub/test-msk-backup-kafka-connect|*|Write|Allow|Topic|pubsub.restore-test.customer-proposition.service-status.events.v4|Literal]
kafka_topic.restore_account_identity_supply_address_debt_exception_check_events: Creation complete after 2s [id=pubsub.restore-test.account-identity.supply.address.debt.exception.check.events]
kafka_topic.restore_iam_credentials_v1: Creation complete after 2s [id=pubsub.restore-test.auth-customer.iam-credentials-v1]
kafka_topic.restore_account_identity_internal_legacy_account_events: Creation complete after 1s [id=pubsub.restore-test.account-identity.internal.legacy.account.events]
kafka_topic.restore_events_end: Creation complete after 1s [id=pubsub.restore-test.data-infra.uw.data-infra.product.v1.eventsend]
kafka_topic.restore_billing_engine_events_bce_deadletter: Creation complete after 1s [id=pubsub.restore-test.billing.billing-engine-events-bce-deadletter]
Warning: Argument is deprecated
with provider["registry.terraform.io/mongey/kafka"],
on __env.tf line 12, in provider "kafka":
12: provider "kafka" {
This parameter is now deprecated and will be removed in a later release,
please use `client_key` instead.
(and one more similar warning elsewhere)
Apply complete! Resources: 38 added, 0 changed, 0 destroyed.
|
|
Terraform run output for ✅ Run Status: Ok, Run Summary: Apply complete! Resources: 0 added, 1 changed, 0 destroyedTerraform used the selected providers to generate the following execution
plan. Resource actions are indicated with the following symbols:
~ update in-place
Terraform will perform the following actions:
# aws_s3_bucket_lifecycle_configuration.msk_topics_retention will be updated in-place
~ resource "aws_s3_bucket_lifecycle_configuration" "msk_topics_retention" {
id = "uw-dev-pubsub-msk-backup"
# (4 unchanged attributes hidden)
~ rule {
~ id = "pubsub.restore-test.energy-platform.meter.read.events.v3" -> "pubsub.restore-test.auth-customer.iam-credentials-v1"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 8
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/pubsub.restore-test.energy-platform.meter.read.events.v3/" -> "msk-backup-parquet/pubsub.restore-test.auth-customer.iam-credentials-v1/"
}
}
~ rule {
~ id = "unicom.bill-events" -> "pubsub.restore-test.auth.iam-identitydb-v1"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/unicom.bill-events/" -> "msk-backup-parquet/pubsub.restore-test.auth.iam-identitydb-v1/"
}
}
~ rule {
~ id = "unicom.bill-failed" -> "pubsub.restore-test.billing.bill-reconciliation-error-events"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/unicom.bill-failed/" -> "msk-backup-parquet/pubsub.restore-test.billing.bill-reconciliation-error-events/"
}
}
~ rule {
~ id = "unicom.bounce.2019.1" -> "pubsub.restore-test.billing.billing-engine-events-bce-deadletter"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/unicom.bounce.2019.1/" -> "msk-backup-parquet/pubsub.restore-test.billing.billing-engine-events-bce-deadletter/"
}
}
~ rule {
~ id = "unicom.cancel-status.1" -> "pubsub.restore-test.billing.fixed-width-file-processing-events"
# (2 unchanged attributes hidden)
~ expiration {
~ days = 92 -> 31
# (1 unchanged attribute hidden)
}
~ filter {
~ prefix = "msk-backup-parquet/unicom.cancel-status.1/" -> "msk-backup-parquet/pubsub.restore-test.billing.fixed-width-file-processing-events/"
}
}
~ rule {
~ id = "unicom.cancellation.1" -> "pubsub.restore-test.energy-platform.meter.read.events.v3"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.cancellation.1/" -> "msk-backup-parquet/pubsub.restore-test.energy-platform.meter.read.events.v3/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.caps-consent" -> "pubsub.restore-test.unicom.tests"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.caps-consent/" -> "msk-backup-parquet/pubsub.restore-test.unicom.tests/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.caps" -> "unicom.bill-events"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.caps/" -> "msk-backup-parquet/unicom.bill-events/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.clx-report" -> "unicom.bill-failed"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.clx-report/" -> "msk-backup-parquet/unicom.bill-failed/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.comms-fallback.1" -> "unicom.bounce.2019.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.comms-fallback.1/" -> "msk-backup-parquet/unicom.bounce.2019.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.cost-calculated.1" -> "unicom.cancel-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.cost-calculated.1/" -> "msk-backup-parquet/unicom.cancel-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-batch.1" -> "unicom.cancellation.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-batch.1/" -> "msk-backup-parquet/unicom.cancellation.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-post-delivery.1" -> "unicom.caps-consent"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-post-delivery.1/" -> "msk-backup-parquet/unicom.caps-consent/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-critical.1" -> "unicom.caps"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-critical.1/" -> "msk-backup-parquet/unicom.caps/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-important.1" -> "unicom.clx-report"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-important.1/" -> "msk-backup-parquet/unicom.clx-report/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-mock-critical.1" -> "unicom.comms-fallback.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-mock-critical.1/" -> "msk-backup-parquet/unicom.comms-fallback.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-mock-important.1" -> "unicom.cost-calculated.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-mock-important.1/" -> "msk-backup-parquet/unicom.cost-calculated.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-mock.1" -> "unicom.email-batch.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-mock.1/" -> "msk-backup-parquet/unicom.email-batch.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-ses-critical.1" -> "unicom.email-post-delivery.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-ses-critical.1/" -> "msk-backup-parquet/unicom.email-post-delivery.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-ses-important.1" -> "unicom.email-released-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-ses-important.1/" -> "msk-backup-parquet/unicom.email-released-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released-ses.1" -> "unicom.email-released-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released-ses.1/" -> "msk-backup-parquet/unicom.email-released-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-released.1" -> "unicom.email-released-mock-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-released.1/" -> "msk-backup-parquet/unicom.email-released-mock-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.email-status.1" -> "unicom.email-released-mock-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.email-status.1/" -> "msk-backup-parquet/unicom.email-released-mock-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.failed" -> "unicom.email-released-mock.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.failed/" -> "msk-backup-parquet/unicom.email-released-mock.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.go-inspire-letter-status.1" -> "unicom.email-released-ses-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.go-inspire-letter-status.1/" -> "msk-backup-parquet/unicom.email-released-ses-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-batch-critical.1" -> "unicom.email-released-ses-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-batch-critical.1/" -> "msk-backup-parquet/unicom.email-released-ses-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-batch-important.1" -> "unicom.email-released-ses.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-batch-important.1/" -> "msk-backup-parquet/unicom.email-released-ses.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-batch.1" -> "unicom.email-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-batch.1/" -> "msk-backup-parquet/unicom.email-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-critical.1" -> "unicom.email-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-critical.1/" -> "msk-backup-parquet/unicom.email-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-important.1" -> "unicom.failed"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-important.1/" -> "msk-backup-parquet/unicom.failed/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-mock-critical.1" -> "unicom.go-inspire-letter-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-mock-critical.1/" -> "msk-backup-parquet/unicom.go-inspire-letter-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-mock-important.1" -> "unicom.letter-batch-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-mock-important.1/" -> "msk-backup-parquet/unicom.letter-batch-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released-mock.1" -> "unicom.letter-batch-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released-mock.1/" -> "msk-backup-parquet/unicom.letter-batch-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-released.1" -> "unicom.letter-batch.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-released.1/" -> "msk-backup-parquet/unicom.letter-batch.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-send-adare" -> "unicom.letter-released-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-send-adare/" -> "msk-backup-parquet/unicom.letter-released-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.letter-status.1" -> "unicom.letter-released-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.letter-status.1/" -> "msk-backup-parquet/unicom.letter-released-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.mparticle-output-integration" -> "unicom.letter-released-mock-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.mparticle-output-integration/" -> "msk-backup-parquet/unicom.letter-released-mock-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.orchestration-entity.1" -> "unicom.letter-released-mock-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.orchestration-entity.1/" -> "msk-backup-parquet/unicom.letter-released-mock-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.orchestration-rule-execution.1" -> "unicom.letter-released-mock.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.orchestration-rule-execution.1/" -> "msk-backup-parquet/unicom.letter-released-mock.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.outbound-call-request" -> "unicom.letter-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.outbound-call-request/" -> "msk-backup-parquet/unicom.letter-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.push-notification-released.1" -> "unicom.letter-send-adare"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.push-notification-released.1/" -> "msk-backup-parquet/unicom.letter-send-adare/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.push-notification-status.1" -> "unicom.letter-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.push-notification-status.1/" -> "msk-backup-parquet/unicom.letter-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.rejected" -> "unicom.mparticle-output-integration"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.rejected/" -> "msk-backup-parquet/unicom.mparticle-output-integration/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.rendered.1" -> "unicom.orchestration-entity.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.rendered.1/" -> "msk-backup-parquet/unicom.orchestration-entity.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.requests" -> "unicom.orchestration-rule-execution.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.requests/" -> "msk-backup-parquet/unicom.orchestration-rule-execution.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.scheduled.1" -> "unicom.outbound-call-request"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.scheduled.1/" -> "msk-backup-parquet/unicom.outbound-call-request/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.send-notification.1" -> "unicom.push-notification-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.send-notification.1/" -> "msk-backup-parquet/unicom.push-notification-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sftp-status" -> "unicom.push-notification-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sftp-status/" -> "msk-backup-parquet/unicom.push-notification-status.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-batch.1" -> "unicom.rejected"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-batch.1/" -> "msk-backup-parquet/unicom.rejected/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-released-critical.1" -> "unicom.rendered.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-released-critical.1/" -> "msk-backup-parquet/unicom.rendered.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-released-important.1" -> "unicom.requests"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-released-important.1/" -> "msk-backup-parquet/unicom.requests/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-released.1" -> "unicom.scheduled.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-released.1/" -> "msk-backup-parquet/unicom.scheduled.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.sms-status.1" -> "unicom.send-notification.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.sms-status.1/" -> "msk-backup-parquet/unicom.send-notification.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-bill-email-connector" -> "unicom.sftp-status"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-bill-email-connector/" -> "msk-backup-parquet/unicom.sftp-status/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-energy-smets1-notifier" -> "unicom.sms-batch.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-energy-smets1-notifier/" -> "msk-backup-parquet/unicom.sms-batch.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-finance-email-delivery-engine" -> "unicom.sms-released-critical.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-finance-email-delivery-engine/" -> "msk-backup-parquet/unicom.sms-released-critical.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status-v2" -> "unicom.sms-released-important.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status-v2/" -> "msk-backup-parquet/unicom.sms-released-important.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.status" -> "unicom.sms-released.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.status/" -> "msk-backup-parquet/unicom.sms-released.1/"
}
# (1 unchanged block hidden)
}
~ rule {
~ id = "unicom.tests" -> "unicom.sms-status.1"
# (2 unchanged attributes hidden)
~ filter {
~ prefix = "msk-backup-parquet/unicom.tests/" -> "msk-backup-parquet/unicom.sms-status.1/"
}
# (1 unchanged block hidden)
}
+ rule {
+ id = "unicom.status-bill-email-connector"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status-bill-email-connector/"
}
}
+ rule {
+ id = "unicom.status-energy-smets1-notifier"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status-energy-smets1-notifier/"
}
}
+ rule {
+ id = "unicom.status-finance-email-delivery-engine"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status-finance-email-delivery-engine/"
}
}
+ rule {
+ id = "unicom.status-v2"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status-v2/"
}
}
+ rule {
+ id = "unicom.status"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.status/"
}
}
+ rule {
+ id = "unicom.tests"
+ status = "Enabled"
# (1 unchanged attribute hidden)
+ expiration {
+ days = 92
+ expired_object_delete_marker = false
}
+ filter {
+ prefix = "msk-backup-parquet/unicom.tests/"
}
}
# (126 unchanged blocks hidden)
}
Plan: 0 to add, 1 to change, 0 to destroy.
aws_s3_bucket_lifecycle_configuration.msk_topics_retention: Modifying... [id=uw-dev-pubsub-msk-backup]
aws_s3_bucket_lifecycle_configuration.msk_topics_retention: Still modifying... [id=uw-dev-pubsub-msk-backup, 00m10s elapsed]
aws_s3_bucket_lifecycle_configuration.msk_topics_retention: Still modifying... [id=uw-dev-pubsub-msk-backup, 00m20s elapsed]
aws_s3_bucket_lifecycle_configuration.msk_topics_retention: Still modifying... [id=uw-dev-pubsub-msk-backup, 00m30s elapsed]
aws_s3_bucket_lifecycle_configuration.msk_topics_retention: Still modifying... [id=uw-dev-pubsub-msk-backup, 00m40s elapsed]
aws_s3_bucket_lifecycle_configuration.msk_topics_retention: Still modifying... [id=uw-dev-pubsub-msk-backup, 00m50s elapsed]
aws_s3_bucket_lifecycle_configuration.msk_topics_retention: Modifications complete after 57s [id=uw-dev-pubsub-msk-backup]
Apply complete! Resources: 0 added, 1 changed, 0 destroyed.
|
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
adding resources for testing a broader restore