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)
  }
}

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)
  }
}

# There is no Debezium source set up for the content_review database in dev:
# https://github.com/theorchard/terraform-infra/tree/master/dev/kafka-infra/debezium_source,
# so there is no cdc.contentReview.reviewQueue topic.