resource "kafka_topic" "ows_collaborator_topics" {
  for_each = toset([
    "collaborator",
    "recipient",
    "report",
    "split",
    "split_type",
    "statement_period",
    "track_split_mapping",
    "transaction",
    "transferwise_batch",
    "transferwise_profile",
    "transferwise_transaction",
    "vendor_agreement",
  ])

  name               = "cdc.ows_collaborator.${each.value}"
  replication_factor = 3
  partitions         = 1
  config = {
    "retention.ms" = "86400000"
  }
}