Важные изменения (не совместимые с предыдущими релизами)!
CurrentOffset (ТекущееСмещение) - Удалена, вместо этого данные о смещении следует получать из структуры сообщения
CommitOffset (ЗафиксироватьСмещение) - Изменено количество и порядок параметров, 1 - Название топика, 2 - Смещение, 3 - Партиция
Produce (ОтправитьСообщение) - Изменено количество и порядок параметров, 1 - Сообщение, 2 - Название топика, 3 - Партиция, 4 - Ключ, 5 - Заголовки
InitializeConsumer (ИнициализироватьПродюсера) - Изменено количество параметров. Удален параметр №2 (Название топика)
ProduceWithWaitResult (ОтправитьСообщениеСОжиданиемРезультата) - Синхронная отправка сообщения. Тип возвращаемого результата - булево (Истина - получено подтверждение от брокера, Ложь - не получено подтверждение)
- Теперь в рамках одного консьюмера можно считывать сообщения из нескольких топиков. В метод Consume - можно передать список топиков, разделенных ",". В структуре полученного сообщения есть вся необходимая информация - из какого топика получено сообщение, из какого раздела и какой оффсет прочитанного сообщения.
- Добавлены callback методы обработки информации (получение, отправка, debug режим вывода информации, статистика)
- Добавлена компонента для linux (x64)
Full Changelog: v1.0.2...v1.1.0