Способ подключения: Внутренний

Важно!

Данное руководство не описывает порядок развертывания Apache Kafka. предполагается, что все компоненты Apache Kafka уже развернуты и подготовлены к работе.

Apache Kafka — это приемник данных. Стоит отметить, что Инжектор 1С для взаимодействия с Apache Kafka использует REST-компонент: Сonfluent Platform, либо Kafka Rest (Arenadata), в частности:

  • Kafka Rest API;

  • Schema Registry.

Примечание

Если Confluent не установлен, установите его: https://docs.confluent.io/platform/current/installation/installing_cp/zip-tar.html

Для создания в Инжекторе 1С нового подключения к Apache Kafka необходимо в меню Инжектора 1С зайти в раздел «Подключения»,

нажать кнопку «Создать» и заполнить форму для создания подключения.

Обязательными для заполнения являются следующие поля формы:

  • Наименование (наименования подключения);

  • Тип подключения: Kafka (Confluent);

  • Параметры подключения:

    • Способ подключения: Внутренний;

    • Настройки для Kafka REST:

      • Протокол;

      • Сервер;

      • Порт;

      • ИД кластера (который мы скопировали в настройках кластера в Confluent).

    • Настройки для Schema Registry:

      • Протокол;

      • Сервер;

      • Порт;

Для Schema Registry в форме для параметров подключения можно указать тип схемы (по умолчанию), выбрать можно из трех вариантов:

  • NONE (нет типа схемы по умолчанию);

  • формат JSON;

  • формат AVRO.

Примечание

Для загрузки в формате AVRO необходимо выбирать способ подключения «Db.Proxy». Он реализует конвертацию json-массивов, генерируемых Инжектором 1С, в бинарный формат AVRO.

При необходимости можно указать таймаут как для Kafka REST, так и для Schema Registry.

Далее, нажмите кнопку «Проверить подключение». Если возникла ошибка, то необходимо:

  • убедиться, что у расширения «Инжектор 1С» снят флаг «Безопасный режим» (см. статью «Установка»).

  • Если проблема не устранена, то обратитесь к Вашим системным администраторам.

Затем нажмите «Записать и закрыть».

Готово! Подключение настроено, его можно использовать в проектах для загрузки данных.