Для выполнения действий необходимы учётные данные:
user— имя пользователя, от которого будет запускаться выполнение действия.password— пароль пользователя, от имени которого будет запускаться выполнение действия.
CreateKafkaTopics — создаёт новые топики в Kafka.
Пример запроса
securityProtocol: SASL_PLAINTEXT
saslMechanism: PLAIN
partitions: 1
replication_factor: 1
configs: {}
topics:
- example_1
- example_2Спецификация запроса
| Название | Обязательность | Описание | Возможные значения |
|---|---|---|---|
| securityProtocol | Да | Протокол для подключения к Kafka. Подробнее — в документации Kafka | PLAINTEXT, SASL_PLAINTEXT, SASL_SSL |
| saslMechanism | Нет | Механизм аутентификации, который будет использовать SASL. Обязателен при использовании протокола SASL_PLAINTEXT или SASL_SSL. Подробнее — в документации Kafka | PLAIN, SCRAM-SHA-256, SCRAM-SHA-512 |
| partitions | Да | Количество разделов (партиций), на которые будет разделён топик | - |
| replication_factor | Да | Количество копий (реплик) каждой партиции топика, которые необходимо разместить на разных брокерах | - |
| configs | Да | Конфигурация в формате ключ-значение для создаваемых топиков | Значения приведены в документации Kafka |
| topics | Да | Список названий топиков, которые необходимо создать | - |