Вернуться наверх

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

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

Для работы с данными в Managed Kafka установите сетевое соединение с брокерами кластера.

Примечание

В руководстве приведен пример подключения с использованием macOS или UNIX-подобных систем.

Проверить подключение ​

  1. Получите список доступных топиков кластера:

    bash
    "$KAFKA_HOME/bin/kafka-topics.sh" \      # Запуск утилиты для работы с топиками Kafka
  --bootstrap-server "$BOOTSTRAP" \      # Адрес брокера
  --command-config "$CONF" \             # Файл конфигурации Kafka
  --list                                 # Флаг для вывода списка всех доступных топиков

    Если подключение к кластеру успешно, в ответе будет выведен список доступных топиков кластера. Если вы еще не создали ни одного топика, будет выведен список из одного системного топика Kafka __consumer__offsets.

  2. Запустите консольного производителя для записи и отправки сообщений:

    bash
    "$KAFKA_HOME/bin/kafka-console-producer.sh" \     # Запуск консольного производителя для отправки тестовых сообщений в топик
  --bootstrap-server "$BOOTSTRAP" \               # Адрес брокера
  --producer.config "$CONF" \                     # Файл конфигурации Kafka
  --topic "$TOPIC"                                # Целевой топик

    После запуска введите сообщение для записи и отправки потребителю.

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

    bash
    "$KAFKA_HOME/bin/kafka-console-consumer.sh" \     # Запуск консольного потребителя для чтения сообщений из топика
  --bootstrap-server "$BOOTSTRAP" \               # Адрес брокера
  --consumer.config "$CONF" \                     # Файл конфигурации Kafka
  --topic "$TOPIC" \                              # Целевой топик
  --group <группа потребителей> \                 # Идентификатор группы потребителей
  --from-beginning                                # Чтение всех сообщений с начала топика

    В ответе будут выведены сообщения, отправленные в предыдущем шаге.