1
resource "mws_vpc_network" "network" {
2
  network = var.network_name
3
}
4

5
resource "mws_vpc_subnet" "subnet_a" {
6
  subnet  = "${var.subnet_name}-a"
7
  network = mws_vpc_network.network.network
8
  cidr    = var.subnet_cidr_a
9
}
10

11
resource "mws_vpc_subnet" "subnet_b" {
12
  subnet  = "${var.subnet_name}-b"
13
  network = mws_vpc_network.network.network
14
  cidr    = var.subnet_cidr_b
15
}
16

17
resource "mws_vpc_address" "broker_addr_1" {
18
  address = "${var.kafka_name}-broker-addr-1"
19
  network = mws_vpc_network.network.network
20
  subnet  = mws_vpc_subnet.subnet_a.metadata.id
21
}
22

23
resource "mws_vpc_address" "broker_addr_2" {
24
  address = "${var.kafka_name}-broker-addr-2"
25
  network = mws_vpc_network.network.network
26
  subnet  = mws_vpc_subnet.subnet_b.metadata.id
27
}
28

29
resource "mws_vpc_address" "broker_addr_3" {
30
  address = "${var.kafka_name}-broker-addr-3"
31
  network = mws_vpc_network.network.network
32
  subnet  = mws_vpc_subnet.subnet_b.metadata.id
33
}
34

35
resource "mws_mkafka_cluster" "example" {
36
  cluster = var.kafka_name
37
  version = "4.0"
38

39
  metadata = {
40
    display_name = "Example Kafka Cluster"
41
    description  = "Managed Kafka cluster example with VPC endpoints"
42
  }
43

44
  active = true
45

46
  endpoints = [
47
    {
48
      name    = "vpc-endpoint"
49
      network = mws_vpc_network.network.metadata.id
50
      broker_addresses = [
51
        { ref = mws_vpc_address.broker_addr_1.id },
52
        { ref = mws_vpc_address.broker_addr_2.id },
53
        { ref = mws_vpc_address.broker_addr_3.id }
54
      ]
55
    }
56
  ]
57

58
  instances = {
59
    broker = {
60
      vm_type = "compute/vmTypes/gen-2-4"
61
      disk = {
62
        size = "10Gb"
63
        type = "NETWORK_STANDARD_SSD"
64
      }
65
      allocation = [
66
        {
67
          zone  = "ru-central1-b"
68
          count = 3
69
        }
70
      ]
71
    }
72
    controller = {
73
      vm_type = "compute/vmTypes/gen-2-4"
74
      disk = {
75
        size = "10Gb"
76
        type = "NETWORK_STANDARD_SSD"
77
      }
78
      allocation = [
79
        {
80
          zone  = "ru-central1-b"
81
          count = 3
82
        }
83
      ]
84
    }
85
  }
86

87
  maintenance_window = {
88
    weekly = {
89
      days = ["TUESDAY"]
90
      hour = 4
91
    }
92
  }
93
}
94

95
resource "mws_mkafka_topic" "example" {
96
  cluster = mws_mkafka_cluster.example.cluster
97
  topic   = var.topic_name
98

99
  metadata = {
100
    display_name = "Example Kafka Topic"
101
    description  = "A sample Kafka topic with custom configuration"
102
  }
103

104
  partitions         = 6
105
  replication_factor = 3
106

107
  config = {
108
    "cleanup.policy" = "compact,delete"
109
    "retention.ms"   = "604800000"  # 7 days
110
    "segment.bytes"  = "1073741824" # 1GB
111
  }
112
}
113

114
variable "network_name" {
115
  type        = string
116
  default     = "kafka-vpc-network"
117
  description = "VPC network name"
118
}
119

120
variable "subnet_name" {
121
  type        = string
122
  default     = "kafka-subnet"
123
  description = "Base name for subnets"
124
}
125

126
variable "subnet_cidr_a" {
127
  type        = string
128
  default     = "192.168.1.0/24"
129
  description = "CIDR for subnet A"
130
}
131

132
variable "subnet_cidr_b" {
133
  type        = string
134
  default     = "192.168.2.0/24"
135
  description = "CIDR for subnet B"
136
}
137

138
variable "kafka_name" {
139
  type        = string
140
  default     = "kafka-cluster"
141
  description = "Kafka cluster name"
142
}
143

144
variable "topic_name" {
145
  type        = string
146
  default     = "example-topic"
147
  description = "Kafka topic name"
148
}