resource "kafka_topic" "event_abacus_contract" {
  name               = "event.abacus.contract"
  replication_factor = var.kafka_minimum_replication_factor
  partitions         = 3
  config = {
    "max.message.bytes" = "15728640"
    "retention.ms"      = tostring(var.one_day_ms)
    "min.insync.replicas" = "2"
  }
}