mws_mkafka_cluster (Data Source)
Кластер Managed Kafka — это группа узлов (брокеров), объединенных для приема, хранения и передачи потоков данных с помощью Apache Kafka. В облачной инфраструктуре кластер — единый интерфейс для управления потоками данных в реальном времени
Пример использования
terraform
data "mws_mkafka_cluster" "mkafka_kafka" {
cluster = "example-cluster"
}Schema
Required
cluster(String) Название или идентификатор кластера.
Optional
project(String) Путь к проекту
Read-Only
active(Boolean) Значение включен/выключен кластер.endpoints(Attributes List) Описание эндпойнтов в сетях пользователя (VPC) для подключения к брокерам кластера. (see below for nested schema)instances(Attributes) Описание ресурсов хостов брокеров и контроллеров. (see below for nested schema)kind(String)maintenance_window(Attributes) (see below for nested schema)metadata(Attributes) (see below for nested schema)product_config(String) Настройки Kafka. Если не указаны, будут использованы настройки по-умолчанию.schema_registry(Attributes) Настройка Schema Registry для кластера. (see below for nested schema)status(Attributes) (see below for nested schema)version(String) Версия продукта.
Nested Schema for endpoints
Read-Only:
broker_addresses(Attributes List) Список адресов в пользовательской сети, на которые "отображаются" брокеры. (see below for nested schema)external_access(Attributes) Настройка внешнего доступа к кластеру Kafka. (see below for nested schema)name(String) Имя эндпойнта.network(String) Идентификатор пользовательской сети (VPC).
Nested Schema for endpoints.broker_addresses
Read-Only:
ref(String) Идентификатор существующего адреса.spec(Attributes) Спецификация нового адреса. Адрес будет выделен в ходе реконсиляции кластера. (see below for nested schema)
Nested Schema for endpoints.broker_addresses.spec
Read-Only:
subnet(String) Идентификатор подсети, в которой необходимо выделить адрес.
Nested Schema for endpoints.external_access
Read-Only:
allowed(Boolean) Назначить внешние адреса для кластера Kafka.broker_addresses(Attributes List) Список внешних адресов, используемых для настройки доступа к кластеру Kafka. Если флаг "allowed" установлен в true и адреса не указаны, внешние адреса будут выделены автоматически. (see below for nested schema)
Nested Schema for endpoints.external_access.broker_addresses
Read-Only:
ref(String) Идентификатор существующего внешнего адреса.spec(Attributes) Спецификация нового внешнего адреса. Адрес будет выделен в ходе реконсиляции кластера. (see below for nested schema)
Nested Schema for endpoints.external_access.broker_addresses.spec
Nested Schema for instances
Read-Only:
broker(Attributes) Параметры виртуальной машины, где будет работать брокер Кафки. (see below for nested schema)controller(Attributes) Параметры виртуальной машины, где будет работать KRaft контроллер Кафки. (see below for nested schema)
Nested Schema for instances.broker
Read-Only:
allocation(Attributes List) Параметры размещения брокеров по зонам. (see below for nested schema)disk(Attributes) Параметры диска с данными на узле кластера. (see below for nested schema)vm_type(String) Тип виртуальной машины, описывающий ресурсы (vCPU, memory).
Nested Schema for instances.broker.allocation
Read-Only:
count(Number) Количество брокеров в зоне/подсети.zone(String) Зона расположения узла.
Nested Schema for instances.broker.disk
Read-Only:
iops(Number) Количество дисковых операций в секунду.size(String) Размер диска.type(String) Тип используемого диска:
- "NETWORK_STANDARD_SSD" — сетевой SSD
Nested Schema for instances.controller
Read-Only:
allocation(Attributes List) Параметры размещения контроллеров по зонам. (see below for nested schema)combined_with_broker(Boolean) Размещать контроллеры на тех же виртуальных машинах, что и брокерыdisk(Attributes) Параметры диска с данными на узле кластера. (see below for nested schema)vm_type(String) Тип виртуальной машины, описывающий ресурсы (vCPU, memory).
Nested Schema for instances.controller.allocation
Read-Only:
count(Number) Количество брокеров в зоне/подсети.zone(String) Зона расположения узла.
Nested Schema for instances.controller.disk
Read-Only:
iops(Number) Количество дисковых операций в секунду.size(String) Размер диска.type(String) Тип используемого диска:
- "NETWORK_STANDARD_SSD" — сетевой SSD
Nested Schema for maintenance_window
Read-Only:
weekly(Attributes) (see below for nested schema)
Nested Schema for maintenance_window.weekly
Read-Only:
days(List of String) Дни недели, в который будет запущено задание на тех.обслуживаниеduration(String) Допустимая продолжительность процесса обновления. Если не указано, то не ограничено по времени. Принимается только формат в часах (h)hour(Number) Час, в который будет запущено задание на тех.обслуживание
Nested Schema for metadata
Read-Only:
create_time(String) Дата создания объекта.delete_time(String) Время запроса на удаление ресурса (не фактическое время удаления).description(String) Описание ресурса.display_name(String) Отображаемое имя. Необязательное поле, можно свободно задавать и изменять для удобства организации ресурсов.id(String) ссылка на типизированный референсpurge_time(String)usages(Attributes List) Связи с другими ресурсами. В зависимости от типа связи, операции над ресурсом могут быть ограничены. (see below for nested schema)
Nested Schema for metadata.usages
Read-Only:
name(String) Имя связи, требуется для модификации коллекцииresource(String) ссылка на ресурсusage_type(String) Тип связи. Помимо стандартных own и use могут быть добавлены специализированные типы для конкретных сервисов
Nested Schema for schema_registry
Read-Only:
enabled(Boolean) Включить Schema Registry в кластере.
Nested Schema for status
Read-Only:
effective_kafka_config(Map of String) Конфигурация параметров кластера после валидации и преобразования из пользователского вводаendpoints(Attributes List) Описание эндпойнтов в сетях пользователя (VPC) для подключения к брокерам кластера. (see below for nested schema)health(String) Работоспособность кластера- "ALIVE" - Полностью работоспособен
- "DEGRADED" - Деградирует (некоторые, но не все, экземпляры неработоспособны)
- "FAILED" - Неработоспособен
- "UNKNOWN" - Не удаётся определить состояние (на этапе создания)
instances(Attributes) Описание ресурсов хостов брокеров и контроллеров. (see below for nested schema)maintenance_window(Attributes) (see below for nested schema)message(String)ready(Attributes) Информация о статусе реконсиляции (see below for nested schema)schema_registry(Attributes) Настройка Schema Registry для кластера. (see below for nested schema)state(String) Состояние кластера- "CREATING" - Создаётся
- "RUNNING" - Работает в штатном режиме
- "STOPPING" - Останавливается
- "STOPPED" - Остановлен
- "STARTING" - Запуск ранее остановленного
- "UPDATING" - Выполняется обновление
- "ERROR" - Произошла ошибка, требуется участие команды поддержки
- "DELETING" - Удаляется
- "DELETED" - Удалён
- "UNIDENTIFIED" - Не удаётся определить статус
- "RESTORING" - Восстанавливается
Nested Schema for status.endpoints
Read-Only:
bootstrap_servers(String) Список адресов для первоначального подключения к кластеру внутри пользовательской (VPC).broker_addresses(Attributes List) Список адресов в пользовательской сети, на которые "отображаются" брокеры. (see below for nested schema)external_access(Attributes) Настройка внешнего доступа к кластеру Kafka. (see below for nested schema)name(String) Имя эндпойнта.network(String) Идентификатор пользовательской сети (VPC).port(Number) Порт для доступа к кластеру Kafka внутри пользовательской сети (VPC).schema_registry(Attributes) Адреса Schema Registry во внутренней сети (VPC). (see below for nested schema)
Nested Schema for status.endpoints.broker_addresses
Read-Only:
dns(Attributes List) Доменные имена. (see below for nested schema)ip_address(String) Выделенный адрес.ref(String) Идентификатор адреса.subnet(String) Подсеть, в которой выделен адрес.
Nested Schema for status.endpoints.broker_addresses.dns
Read-Only:
name(String)
Nested Schema for status.endpoints.external_access
Read-Only:
allowed(Boolean) Назначить внешние адреса для кластера Kafka.bootstrap_servers(String) Список адресов для первоначального подключения к кластеру Apache Kafka из внешней сети.broker_addresses(Attributes List) Список внешних адресов, выделенных для брокеров Kafka. (see below for nested schema)port(Number) Порт, используемый для доступа к кластеру Kafka из внешней сети.schema_registry(Attributes) Внешние HTTPS-адреса Schema Registry. (see below for nested schema)
Nested Schema for status.endpoints.external_access.broker_addresses
Read-Only:
ip_address(String) Выделенный адрес.managed(Boolean) False если ссылка на внешний адрес был указана в спецификации, true если адрес был созданref(String) Идентификатор адреса.
Nested Schema for status.endpoints.external_access.schema_registry
Read-Only:
urls(List of String) Список HTTPS URL Schema Registry.
Nested Schema for status.endpoints.schema_registry
Read-Only:
urls(List of String) Список HTTPS URL Schema Registry.
Nested Schema for status.instances
Read-Only:
broker(Attributes) Параметры виртуальной машины, где работает брокер Кафки. (see below for nested schema)controller(Attributes) Параметры виртуальной машины, где работает контроллер. (see below for nested schema)
Nested Schema for status.instances.broker
Read-Only:
disk(Attributes) Параметры диска с данными на узле кластера Managed Kafka. (see below for nested schema)
Nested Schema for status.instances.broker.disk
Read-Only:
iops(Number) Количество дисковых операций в секунду.
Nested Schema for status.instances.controller
Read-Only:
combined_with_broker(Boolean) Контроллеры размещаются на тех же виртуальных машинах, что и брокерыdisk(Attributes) Параметры диска с данными на узле кластера Managed Kafka. (see below for nested schema)
Nested Schema for status.instances.controller.disk
Read-Only:
iops(Number) Количество дисковых операций в секунду.
Nested Schema for status.maintenance_window
Read-Only:
weekly(Attributes) (see below for nested schema)
Nested Schema for status.maintenance_window.weekly
Read-Only:
days(List of String) Дни недели, в который будет запущено задание на тех.обслуживаниеduration(String) Допустимая продолжительность процесса обновления. Если не указано, то не ограничено по времени. Принимается только формат в часах (h)hour(Number) Час, в который будет запущено задание на тех.обслуживание
Nested Schema for status.ready
Read-Only:
message(String) Описание статусаstate(String) Состояние ресурса
Nested Schema for status.schema_registry
Read-Only:
enabled(Boolean) Включить Schema Registry в кластере.