Поделиться через

Добавление Apache Kafka в качестве источника в концентраторе реального времени (предварительная версия)

  • Статья

В этой статье описывается, как добавить Apache Kafka в качестве источника событий в Концентраторе реального времени Fabric.

Необходимые компоненты

  • Доступ к рабочей области в режиме лицензии емкости Fabric (или) режим пробной лицензии с разрешениями участника или более высокого уровня.
  • Запущен кластер Apache Kafka.
  • Apache Kafka должен быть общедоступным, а не за брандмауэром или защищенным в виртуальной сети. 

Страница «Источники данных»

  1. Войдите в Microsoft Fabric.

  2. Выберите режим реального времени на левой панели навигации.

  3. На странице центра реального времени выберите +Источники данных в разделе "Подключиться" в меню навигации слева. Вы также можете добраться до страницы источников данных из всех потоков данных или страниц "Мои потоки данных", нажав кнопку "+ Подключить источник данных" в правом верхнем углу.

    Снимок экрана, на котором показано, как запустить подключение к источнику данных.

Добавление Apache Kafka в качестве источника

  1. На странице "Выбор источника данных" выберите Apache Kafka.

    Снимок экрана: выбор Apache Kafka в качестве исходного типа в мастере получения событий.

  2. На странице "Подключение" выберите "Создать подключение".

    Снимок экрана: выбор ссылки

  3. В разделе "Параметры подключения" для начального сервера введите адрес сервера Apache Kafka.

    Снимок экрана: выбор поля сервера начальной загрузки на странице

  4. В разделе учетных данных подключения, если у вас есть существующее подключение к кластеру Apache Kafka, выберите его в раскрывающемся списке для подключения. В противном случае выполните следующие действия.

    1. В поле "Имя подключения" введите имя подключения.
    2. Для типа проверки подлинности убедитесь, что выбран ключ API.
    3. В разделе "Ключ и секрет" введите ключ API и секрет ключа.

  5. Нажмите Подключиться. 

  6. Теперь на странице "Подключение" выполните следующие действия.

    1. В поле "Раздел" введите раздел Kafka.

    2. Для группы потребителей введите группу потребителей кластера Apache Kafka. Это поле предоставляет выделенную группу потребителей для получения событий.

    3. Выберите автоматическое смещение сброса, чтобы указать, где начать чтение смещения, если фиксация отсутствует.

    4. Для протокола безопасности значение по умолчанию — SASL_PLAINTEXT.

      Примечание.

      Источник Apache Kafka в настоящее время поддерживает только незашифрованную передачу данных (SASL_PLAINTEXT и PLAINTEXT) между кластером Apache Kafka и Eventstream. Поддержка зашифрованной передачи данных через SSL будет доступна в ближайшее время.

    5. Механизм SASL по умолчанию обычно обычный, если не настроено в противном случае. Вы можете выбрать механизм SCRAM-SHA-256 или SCRAM-SHA-512 , соответствующий вашим требованиям безопасности.

      Снимок экрана: первая страница параметров подключения Apache Kafka.

  7. Выберите Далее. На экране "Рецензирование" и "Создать" просмотрите сводку и нажмите кнопку "Добавить".

Просмотр сведений о потоке данных

  1. На странице "Проверка и подключение" при выборе "Открыть поток событий" мастер открывает поток событий, созданный для вас с выбранным источником Apache Kafka. Чтобы закрыть мастер, нажмите кнопку Закрыть в нижней части страницы.

  2. В концентраторе реального времени перейдите на вкладку потоков данных концентратора реального времени. Обновите страницу. Вы должны увидеть поток данных, созданный для вас.

    Подробные инструкции см. в разделе "Просмотр сведений о потоках данных" в Концентраторе реального времени Fabric.

Связанный контент

Дополнительные сведения об использовании потоков данных см. в следующих статьях: