Базовые команды

Подключение к кластеру

1. На странице кластера перейдите на вкладку Пользователи и создайте пользователя с нужными правами.

2. Подключитесь по SSH к виртуальной машине, созданной ранее в том же проекте, что и кластер Managed Kafka.

3. Создайте файл конфигурации, например cluster.cfg:

   clusters:
   - name: "<custom_config_name>"
     brokers:
     - <private_IP>:<port>
     SASL:
       mechanism: SCRAM-SHA-512
       username: "<login>"
       password: "<password>"
     TLS: null
     security-protocol: SASL_PLAINTEXT
   
   

   Где:

   • <custom_config_name> — произвольное имя конфигурации.

   • <private_IP>, <port> — внутренний IP-адрес и порт брокера. Скопируйте их на странице информации о кластере в блоке Общие параметры.

   • <login>, <password> — имя пользователя и пароль, заданные при создании пользователя.

Отправка сообщений в топик

echo '{"data":1}' | kaf produce <topic_name> --key key1 --header h1:hv1 --config cluster.cfg --cluster "<custom_config_name>"

• <topic_name> — название топика.

  Вы можете заранее создать топик, или он создастся автоматически при первой записи.

• <custom_config_name> — произвольное имя конфигурации.

Чтение сообщений из топика

kaf consume <topic_name> --output json-each-row --config cluster.cfg --cluster "<custom_config_name>"

• <topic_name> — название топика.

• <custom_config_name> — произвольное имя конфигурации.

{"topic":"<topic_name>","partition":0,"offset":0,"timestamp":"2026-04-16T09:45:43.397+03:00","headers":[{"key":"h1","value":"hv1"}],"key":"key1","payload":"{data:1}"}