resource "kafka_topic" "digsysd3-msk02" {
  for_each = toset(local.msk02_topics)

  name               = each.value
  partitions         = 3
  replication_factor = 3

  config = {
    "cleanup.policy" = "delete"
  }
}

locals {
  msk02_topics = [
    "carma-instant-message",
    "Clr-Delta-Perf",
    "Clr-Delta-Prod",
    "contact-change-event",
    "contracting-company-change-event",
    "deal-type-reversion-change-event",
    "dev_oms_config",
    "dev_oms_offset",
    "dev_oms_status",
    "dev_oratest_oms_group_status_change",
    "dev_pgdbmidev_oms_group_status_change",
    "dev-pgtest-eom-group-status-change",
    "do-ocr-event",
    "document-change-event",
    "document-sub-report-generation-event",
    "DRA_CONNECT_config",
    "DRA_CONNECT_offset",
    "DRA_CONNECT_status",
    "dra-dk2",
    "DSRV_DSP_INFO",
    "DSRV_STATUS_CHANGES",
    "eom-group-response",
    "eom-group-status-change",
    "eom-group-status-change-rep",
    "global-artist-roster-change-event",
    "gras-sync-event",
    "GROUP_STATUS_CHANGES",
    "GROUP_STATUS_CHANGES_REP",
    "licensee-change-event",
    "MAX_COMMITTED_STATUS_CHANGES",
    "reindex-preprocess-event",
    "reindex-process-event",
    "sales-agent-change-event",
    "snapshot_pgsnapshot_oms_group_status_change",
    "stage_oms_config",
    "stage_oms_group_status_change",
    "stage_oms_offset",
    "stage_oms_status",
    "sub-label-change-event",
    "test",
    "test_oms_config",
    "test_oms_group_status_change",
    "test_oms_offset",
    "test_oms_status",
    "test-mysql-jdbc-student",
    "test-status-change",
    "user-event",
  ]
}