Получение partition
SkorodumovDS opened this issue · 3 comments
Добрый день.
Возможно ли получение partition аналогично получению смещения, через функцию?
partition в json не возвращается, и по этой причине нет возможности зафиксировать смещение.
Из за отсутствия возможности зафиксировать смещение, консьюмер читает каждый раз сначала, а не с последнего места.
Добрый день. Возможно ли получение partition аналогично получению смещения, через функцию? partition в json не возвращается, и по этой причине нет возможности зафиксировать смещение. Из за отсутствия возможности зафиксировать смещение, консьюмер читает каждый раз сначала, а не с последнего места.
Вам нужно использовать последний релиз. Partition там возвращается. Так же изменены некоторые методы, например, фиксации смещения - там теперь помимо offset нужно указывать партицию (см. описание к последним релизам)
Последний релиз библиотеки?
Или kafka?
Описание к последнем релизам видел, поэтому и интересовался как я могу получить partition если при прослушке сообщения kafka не возвращает мне partition
Последний релиз библиотеки? Или kafka? Описание к последнем релизам видел, поэтому и интересовался как я могу получить partition если при прослушке сообщения kafka не возвращает мне partition
Последний релиз компоненты (только будьте внимательны, там изменено количество параметров в методах)
Вот пример сообщения, полученного из kafka
{
"partition": "0",
"offset": "1689",
"message": "{"TypeOfMessage":"change_step","step":"agreements","phone":"+7","id":128}",
"topic": "Former_LK_1C",
"timestamp": "1693994403706"
}
p.s. еще важный момент - не достаточно просто обновить макет компоненты, нужно так же почистить кэш 1С, т.к. ВК кэшируются в каталог ExtCompT