nishadmehendale

provider "vault" {
  for_each            = toset(var.namespaces)
  alias               = each.key
  namespace           = each.key
}

nishadmehendale

variable "segment" {
    default = {
        "one"  = "30000"
    }
}

variable "cleanup" {
    default = {
        "one"  = "delete"
        "two"  = "compact, delete"

nishadmehendale

variable "topics" {
  default = ["one", "two", "three"]
}

nishadmehendale

resource "kafka_topic" "kafka_topic" {
  for_each           = toset(var.topic_name)
  name               = each.key
  replication_factor = 1
  partitions         = 3
  config = {
    "segment.ms"     = "20000"
    "cleanup.policy" = "compact"
  }
}

nishadmehendale

# Referred from https://registry.terraform.io/providers/Mongey/kafka/latest/docs/resources/topic#argument-reference
resource "kafka_topic" "logs" {
  name               = "systemd_logs"
  replication_factor = 2
  partitions         = 100

  config = {
    "segment.ms"     = "20000"
    "cleanup.policy" = "compact"
  }

nishadmehendale

# Referred from https://registry.terraform.io/providers/Mongey/kafka/latest/docs/resources/topic#argument-reference
provider "kafka" {
  bootstrap_servers = ["localhost:9092"]
}

resource "kafka_topic" "logs" {
  name               = "systemd_logs"
  replication_factor = 2
  partitions         = 3
}

nishadmehendale

topic one:
  segment.ms: "OneSegment"
  cleanup.policy: "OneCleanup"
topic two:
  segment.ms: "TwoSegment"
  cleanup.policy: "TwoCleanup"
topic three:
  default configuration