resource "kafka_topic" "dev_digsys_connect_storage_config" {
  name               = "dev_digsys_connect_storage_config"
  partitions         = 1
  replication_factor = 3
  config = {
    "cleanup.policy" = "compact"
  }
}

resource "kafka_topic" "dev_digsys_connect_storage_offset" {
  name               = "dev_digsys_connect_storage_offset"
  partitions         = 25
  replication_factor = 3
  config = {
    "cleanup.policy" = "compact"
  }
}

resource "kafka_topic" "dev_digsys_connect_storage_status" {
  name               = "dev_digsys_connect_storage_status"
  partitions         = 5
  replication_factor = 3
  config = {
    "cleanup.policy" = "compact"
  }
}

resource "kafka_topic" "dev_oms_group_status_change" {
  name               = "dev_oms_group_status_change"
  partitions         = 25
  replication_factor = 3
  config = {
    "cleanup.policy" = "delete"
  }
}