Добавлены методы для асинхронного использования в режиме тонкого клиента
УстановитьКаталогЛогов(Каталог)
УстановитьФорматЛогов(ФорматИмениФайловЛога)
Изменения в методе ИнициализироватьКонсьюмера. Метод принимает на вход теперь один параметр - Брокер
ИнициализироватьКонсьюмера(Брокер)
Добавлен метод:
Подписаться(Топики)
Добавлены методы:
УстановитьПозицииЧтения(СтрокаJSON)
СтрокаJSON - Строка. В структуре JSON указывается информация в следующем формате
{
"metadata": [
{
"topic": "testTopicParts",
"partition": 0,
"offset": 41
}
]
}metadata - Массив, содержит структуру {topic, partition, offset}. Консьюмер, может быть подписан на разные партиции одного топика или даже на разные топики и разные партиции таких топиков.
topic - Строка. Имя топика.
partition - Число. Номер раздела.
offset - Число. Позиция, с которой нужно начать чтение.
ПолучитьСмещенияГруппыКонсьюмеров(Брокер, ВременнаяМетка, Таймаут);
Брокер - Строка. Брокер, например 192.168.0.139:9092 или список брокеров, разделенных запятой. Порт можно не указывать, так же, если используется кластер, то нет необходимости указывать список всех брокеров, достаточно указать основного брокера. Брокер хранит информацию об других, связанных брокерах кластера.
ВременнаяМетка Строка. Если параметр не задан - из брокера получается последняя зафиксированная информация о смещениях, если значение указано, то смещения, зарегистрированные на данную отметку времени. По умолчанию = ""
Таймаут - Число. Указывается продолжительность ожидания получения ответа от брокера, если по истечении указанного интервала не будет получен ответ - таймаут увеличивается на 1000 ms и повторяется попытка получения данных от брокера. По умолчанию = 5000 ms
Данный метод не является обязательным. Метод возвращает значения JSON строкой следующего формата:
{
"metadata": [
{
"topic": "testTopicParts",
"partition": "0",
"offset": "48"
}
]
}