Links
Comment on page

Получить сообщения

Компонент, получающий сообщения из очереди сервера Kafka.
Свойство
Тип
Описание
Адрес сервера*
String
Адрес сервера Kafka (localhost:9092)
Логин
String
Логин
Пароль
String
Пароль
Имя очереди/топика*
String
Имя очереди/топика
Group ID
String
Group ID
Массив сообщений
Массив полученных сообщений
Ожидать появление
Boolean
Признак ожидания появления нового сообщения в очереди
Таймаут*
Int32
Предельное время ожидания завершения процесса (мс)
C#
Python
JavaScript
List<LTools.Network.MQ.KafkaMessage> ret = LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", true, 10000);
ret = LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", True, 10000)
var ret = _lib.LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", true, 10000);