Связаться с экспертомПопробовать бесплатно
Создавайте контент и получайте гранты!Готовы написать своё руководство? Участвуйте в контент-программе и получайте гранты на работу с облачными сервисами!
Подробнее о программе
Проект Яндекса
© 2026 ТОО «Облачные Сервисы Казахстан»

Подключиться к кластеру Apache Kafka®

Статья создана
Обновлена 2 июня 2026 г.

В данной инструкции мы разберем команды kcat для внешнего и внутреннего подключения к кластеру Apache Kafka® и отправим сообщение от производителя к потребителю.

Если вам нужно быстро получить параметры подключения к кластеру, используйте кнопку Подключиться на странице кластера в консоли управления. Она показывает готовые данные для подключения.

Инструкции ниже описывают ручной сценарий через kubectl, который можно использовать как fallback, если нужно получить параметры подключения через CLI.

Перед началом работы

  1. Установите утилиту kcat.
  2. Если проект еще не создан, создайте его: kubectl create namespace <название проекта>.
  3. Создайте кластер Apache Kafka®.
  4. Создайте топик.
  5. Создайте пользователя с правами администратора.

Как подключиться к кластеру Apache Kafka®

Примечание

Чтобы была возможность подключаться к Apache Kafka® извне кластера, в настройках кластера Apache Kafka® должна быть включена опция публичного доступа (listenerType: LoadBalancer).

  1. Получите внешнюю ссылку на кластер Apache Kafka®: kubectl get kafkaclusters <название кластера> -o jsonpath='{.status.listenersStatus.external.fqdn}' -n <название проекта>.

  2. Получите порт для подключения: kubectl get kafkaclusters <название кластера> -o jsonpath='{.status.listenersStatus.external.port}' -n <название проекта>.

  3. Скопируйте сертификат для подключения из поля status.listenersStatus.external.certificate ресурса кластера Apache Kafka®: kubectl describe kafkaclusters <название кластера> -n <название проекта>.

  4. Сохраните сертификат в файл <путь до сертификата>/ca.crt.

  5. Запустите команду получения сообщений из топика:

    kcat -C \
-b <ссылка на кластер>:<порт> \
-t <название топика> \
-X security.protocol=SASL_SSL \
-X sasl.mechanism=SCRAM-SHA-512 \
-X sasl.username="<имя пользователя>" \
-X sasl.password="<пароль пользователя>" \
-X ssl.endpoint.identification.algorithm=none \
-X ssl.ca.location=/<путь до сертификата>/ca.crt -Z -K:

  6. Откройте новый терминал и отправьте сообщение в топик:

    echo "test message" | kcat -P \
-b <ссылка на кластер>:<порт> \
-t <название топика> \
-k key \
-X security.protocol=SASL_SSL \
-X sasl.mechanism=SCRAM-SHA-512 \
-X sasl.username="<имя пользователя>" \
-X sasl.password="<пароль пользователя>" \
-X ssl.endpoint.identification.algorithm=none \
-X ssl.ca.location=/<путь до сертификата>/ca.crt -Z

Потребитель получит сообщение: "test message".

  1. Получите внутреннюю ссылку на кластер Apache Kafka®: kubectl get kafkaclusters <название кластера> -o jsonpath='{.status.listenersStatus.internal.fqdn}' -n <название проекта>.

  2. Получите порт для подключения: kubectl get kafkaclusters <название кластера> -o jsonpath='{.status.listenersStatus.internal.port}' -n <название проекта>.

  3. Запустите команду получения сообщений из топика:

    kcat -C \
-b <ссылка на кластер>:<порт> \
-t <название топика> \
-X security.protocol=SASL_PLAINTEXT \
-X sasl.mechanism=SCRAM-SHA-512 \
-X sasl.username="<имя пользователя>" \
-X sasl.password="<пароль пользователя>" -Z -K:

  4. Откройте новый терминал и отправьте сообщение в топик:

    echo "test message" | kcat -P \
-b <ссылка на кластер>:<порт> \
-t <название топика> \
-k key \
-X security.protocol=SASL_PLAINTEXT \
-X sasl.mechanism=SCRAM-SHA-512 \
-X sasl.username="<имя пользователя>" \
-X sasl.password="<пароль пользователя>" -Z

Потребитель получит сообщение: "test message".

Предыдущая
Создать пользователя
Следующая
Удалить кластер