resource "kafka_topic" "cdc_content_review_review_queue" {
  name               = "cdc.contentReview.reviewQueue"
  replication_factor = var.kafka_minimum_replication_factor
  partitions         = 10
  config = {
    "retention.ms" = tostring(var.four_hours_ms)
    "min.insync.replicas" = "2"
  }
}

resource "kafka_topic" "event_ows_content_review_product" {
  name               = "event.owsContentReview.product"
  replication_factor = var.kafka_minimum_replication_factor
  partitions         = var.kafka_default_partitions
  config = {
    "retention.ms" = tostring(var.kafka_default_retention_ms)
    "min.insync.replicas" = "2"
  }
}

resource "kafka_topic" "event_ows_content_review_review" {
  name               = "event.owsContentReview.review"
  replication_factor = var.kafka_minimum_replication_factor
  partitions         = var.kafka_default_partitions
  config = {
    "retention.ms" = tostring(var.one_day_ms)
    "min.insync.replicas" = "2"
  }
}

resource "kafka_topic" "stream_content_review_queue_move_history" {
  name               = "stream.contentReview.queueMoveHistory"
  replication_factor = var.kafka_minimum_replication_factor
  partitions         = var.kafka_default_partitions
  config = {
    "retention.ms" = tostring(var.four_hours_ms)
    "min.insync.replicas" = "2"
  }
}

resource "kafka_topic" "event_ows_assets_acr_cloud_audio_infringements" {
  name               = "event.owsAssets.acrCloudAudioInfringements"
  replication_factor = var.kafka_minimum_replication_factor
  partitions         = var.kafka_default_partitions
  config = {
    "retention.ms" = tostring(var.four_hours_ms)
    "min.insync.replicas" = "2"
  }
}