Comment on page
Получить сообщения
.png?alt=media)
Компонент, получающий сообщения из очереди сервера 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);
Last modified 1yr ago