Kafka

Apache Kafka - это платформа распределенной потоковой передачи событий с открытым исходным кодом, которая находит применение во многих отраслях. Kafka работает как кластер из одного или нескольких серверов Kafka, которые взаимодействуют с клиентами. Клиенты могут выступать в роли потребителей, получая сообщения от серверов Kafka, или в роли производителей, публикуя сообщения. Сообщения Kafka (также известные как события или записи в документации) делятся на темы. Каждое сообщение в теме может иметь дополнительный ключ, используемый для организации и разделения сообщений.

Драйвер устройства Kafka - это клиент, который может выступать как в роли потребителя, так и в роли производителя, позволяя SberMobile Server обмениваться сообщениями с серверами Kafka.

Информация о драйвере

Идентификатор Расширения драйвера:

com.tibbo.linkserver.plugin.device.kafka

Глобальные настройки

Не определены.

Настройки уровня пользователя

Не определены.

Свойства аккаунта устройства

Свойства соединения

Настройки соединения определяют, как SberMobile Server будет подключаться к экземплярам Kafka и какие темы будут опрашиваться. Здесь приведен список доступных свойств соединения:

Свойство

Описание

Адреса брокеров

Таблица данных, указывающая подробности о брокере Kafka для первоначального подключения клиента.

  • Адрес брокера. IP-адрес целевого брокера.

  • Номер порта. Номер порта рекламируемых слушателей Kafka на целевом брокере.

Темы

Список тем, на которые будет подписано устройство.

Максимальное количество сообщений, вычитываемое за цикл опроса

Максимальное количество записей, которые будут возвращены по запросу опроса.

Продолжительность опроса (мс)

Максимум времени ожидания ответа во время запроса опроса.

Интервал автоматической фиксации смещения (мс)

Количество времени, в течение которого Смещение потребителей будет автоматически фиксироваться в Kafka.

Активы устройства

Активы не поддерживаются драйвером.

Настройки устройства

Драйвер устройства Kafka создает одну переменную настроек устройства:

Имя переменной

Описание переменной

Комментарии

messageCount

Количество сообщений

Количество полученных сообщений. Значение обновлено при каждой синхронизации. При повторном подключении счетчик обнуляется.

Операции с устройством

Опубликовать текстовое сообщение

Данная функция позволяет устройству выступать в роли производителя сообщений путем записи сообщения в тему.

Формат входных параметров функции имеет следующие поля:

Имя

Тип

Описание

topic

String

Указывает тему, в которой должно быть записано сообщение.

textMessage

String

Значение сообщения.

key

String

Значение ключа для сообщения. Если оставить значение <не задано>, брокер будет автоматически генерировать ключ.

Функция не имеет выходных параметров.

События устройства

Сообщение

Возникает, когда SberMobile Server получает сообщение на одну из тем, перечисленных в свойствах соединения.

Имя события

сообщение

Права доступа:

Доступно на уровне прав Наблюдателя

Записи:

1

Формат записи:

Поле

Тип поля

Заметки

topic

String

Тема сообщения.

key

String

Ключ полученного сообщения.

textMessage

String

Текст полученного сообщения.

partition

String

Указывает, в каком разделе хранится сообщение.

offset

String

Используется для поддержания текущей позиции потребителя и обеспечения того, чтобы одно и то же сообщение не было получено дважды.

key

String

Используется для организации и разделения сообщений внутри темы.

Расширенная информация о синхронизации

Драйвер Kafka опрашивает кластер Kafka и подписывается на темы, указанные в свойствах соединения.

Текущий драйвер пометит устройство как выключенное, если соединение с брокером Kafka не может быть установлено.