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

Компонент, получающий сообщения из очереди сервера Kafka.

Свойство	Тип	Описание
Адрес сервера*	String	Адрес сервера Kafka (localhost:9092)
Логин	String	Логин
Пароль	String	Пароль
Имя очереди/топика*	String	Имя очереди/топика
Group ID	String	Group ID
Массив сообщений	List <LTools.Network.MQ.KafkaMessage>	Массив полученных сообщений
Ожидать появление	Boolean	Признак ожидания появления нового сообщения в очереди
Таймаут*	Int32	Предельное время ожидания завершения процесса (мс)

C#

List<LTools.Network.MQ.KafkaMessage> ret = LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", true, 10000);

Python

ret = LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", True, 10000)

JavaScript

var ret = _lib.LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", true, 10000);