Kafka
Apache Kafka - это платформа распределенной потоковой передачи событий с открытым исходным кодом, которая находит применение во многих отраслях. Kafka работает как кластер из одного или нескольких серверов Kafka, которые взаимодействуют с клиентами. Клиенты могут выступать в роли потребителей, получая сообщения от серверов Kafka, или в роли производителей, публикуя сообщения. Сообщения Kafka (также известные как события или записи в документации) делятся на темы. Каждое сообщение в теме может иметь дополнительный ключ, используемый для организации и разделения сообщений.
Драйвер устройства Kafka - это клиент, который может выступать как в роли потребителя, так и в роли производителя, позволяя AggreGate Server обмениваться сообщениями с серверами Kafka.
Информация о драйвере
Идентификатор Расширения драйвера: | com.tibbo.linkserver.plugin.device.kafka |
Глобальные настройки
Не определены.
Настройки уровня пользователя
Не определены.
Свойства аккаунта устройства
Свойства соединения
Настройки соединения определяют, как AggreGate Server будет подключаться к экземплярам Kafka и какие темы будут опрашиваться. Здесь приведен список доступных свойств соединения:
Свойство | Описание |
Адреса брокеров | Таблица данных, указывающая подробности о брокере Kafka для первоначального подключения клиента.
|
Темы | Список тем, на которые будет подписано устройство. |
Максимальное количество сообщений, вычитываемое за цикл опроса | Максимальное количество записей, которые будут возвращены по запросу опроса. |
Продолжительность опроса (мс) | Максимум времени ожидания ответа во время запроса опроса. |
Интервал автоматической фиксации смещения (мс) | Количество времени, в течение которого Смещение потребителей будет автоматически фиксироваться в Kafka. |
Активы устройства
Активы не поддерживаются драйвером.
Настройки устройства
Драйвер устройства Kafka создает одну переменную настроек устройства:
Имя переменной | Описание переменной | Комментарии |
messageCount | Количество сообщений | Количество полученных сообщений. Значение обновлено при каждой синхронизации. При повторном подключении счетчик обнуляется. |
Операции с устройством
Опубликовать текстовое сообщение
Данная функция позволяет устройству выступать в роли производителя сообщений путем записи сообщения в тему.
Формат входных параметров функции имеет следующие поля:
Имя | Тип | Описание |
topic | String | Указывает тему, в которой должно быть записано сообщение. |
textMessage | String | Значение сообщения. |
key | String | Значение ключа для сообщения. Если оставить значение |
Функция не имеет выходных параметров.
События устройства
Сообщение
Возникает, когда AggreGate Server получает сообщение на одну из тем, перечисленных в свойствах соединения.
Имя события | сообщение |
Права доступа: | Доступно на уровне прав Наблюдателя |
Записи: | 1 |
Формат записи:
Поле | Тип поля | Заметки |
topic | String | Тема сообщения. |
key | String | Ключ полученного сообщения. |
textMessage | String | Текст полученного сообщения. |
partition | String | Указывает, в каком разделе хранится сообщение. |
offset | String | Используется для поддержания текущей позиции потребителя и обеспечения того, чтобы одно и то же сообщение не было получено дважды. |
key | String | Используется для организации и разделения сообщений внутри темы. |
Расширенная информация о синхронизации
Драйвер Kafka опрашивает кластер Kafka и подписывается на темы, указанные в свойствах соединения.
Текущий драйвер пометит устройство как выключенное, если соединение с брокером Kafka не может быть установлено.