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_address" "broker_addr_1" {
12
  address = "${var.kafka_name}-broker-addr-1"
13
  network = mws_vpc_network.network.network
14
  subnet  = mws_vpc_subnet.subnet_a.metadata.id
15
}
16

17
resource "mws_mkafka_cluster" "example" {
18
  cluster = var.kafka_name
19
  version = "3.6.0-mws.1"
20

21
  metadata = {
22
    display_name = "Example Kafka Cluster"
23
    description  = "Managed Kafka cluster example with VPC endpoints"
24
  }
25

26
  active = true
27

28
  endpoints = [
29
    {
30
      name    = "vpc-endpoint"
31
      network = mws_vpc_network.network.network
32
      broker_addresses = [
33
        { ref = mws_vpc_address.broker_addr_1.id },
34
      ]
35
    }
36
  ]
37

38
  instances = {
39
    broker = {
40
      vm_type = "compute/vmTypes/gen-2-4"
41
      disk = {
42
        size = "10Gb"
43
        type = "NETWORK_STANDARD_SSD"
44
      }
45
      allocation = [
46
        {
47
          zone  = "ru-central1-a"
48
          count = 1
49
        }
50
      ]
51
    }
52
    controller = {
53
      vm_type = "compute/vmTypes/gen-2-4"
54
      disk = {
55
        size = "10Gb"
56
        type = "NETWORK_STANDARD_SSD"
57
      }
58
      allocation = [
59
        {
60
          zone  = "ru-central1-a"
61
          count = 1
62
        }
63
      ]
64
    }
65
  }
66

67
  maintenance_window = {
68
    weekly = {
69
      days = ["TUESDAY"]
70
      hour = 4
71
    }
72
  }
73
}
74

75
resource "mws_mkafka_cluster_user" "example_user" {
76
  cluster          = mws_mkafka_cluster.example.cluster
77
  user             = var.kafka_user_name
78
  password         = var.kafka_user_password
79
  password_version = 1 //increase on change password
80

81
  metadata = {
82
    display_name = "Example Kafka User"
83
    description  = "User for accessing the example Kafka cluster"
84
  }
85

86
  roles = [
87
    {
88
      name = "CLUSTER_ADMIN"
89
    }
90
  ]
91
}
92

93
variable "network_name" {
94
  type        = string
95
  default     = "kafka-vpc-network"
96
  description = "VPC network name"
97
}
98

99
variable "subnet_name" {
100
  type        = string
101
  default     = "kafka-subnet"
102
  description = "Base name for subnets"
103
}
104

105
variable "subnet_cidr_a" {
106
  type        = string
107
  default     = "192.168.1.0/24"
108
  description = "CIDR for subnet A"
109
}
110

111
variable "kafka_name" {
112
  type        = string
113
  default     = "kafka-cluster"
114
  description = "Kafka cluster name"
115
}
116

117
variable "kafka_user_name" {
118
  type        = string
119
  default     = "example-user"
120
  description = "Kafka user name"
121
}
122

123
variable "kafka_user_password" {
124
  type        = string
125
  default     = "securePassword123!"
126
  description = "Kafka user password"
127
}