Добрый день Подскажите, пожалуйста, а как можно в библиотеке kafka-go пропустить

Question

Добрый день Подскажите, пожалуйста, а как можно в библиотеке kafka-go пропустить

предыдущие сообщения и получать сообщения с которого остановился в предудущий раз?
Вот например было соединение и оно получило 3 сообщения, потом после, разрыва соединения, добавилось еще 3
Как при повторном соединении получать оставшиеся 3 а не все 6? Говорят, можно так сделать даже без кода на го а настроив zookeeper

#backend #go #programming #russian

0

01.07.2021

3 ответов

17 просмотров

Andrey Panov

Это не фишка го, Кафка умеет двигать курсор для клиента. Возможно да, придется зукипер добавить, но вроде они хотели заменить его

0

01.07.2021

Mike Wazowski

Andrey Panov
Это не фишка го, Кафка умеет двигать курсор для кл...

Оффсеты можно хранить как на клиенте, так и в кафке. Кафка без зукипера не работает, если говорить про стабильную версию. Через годик можно будет протестить. Если хранить оффсете в кафке, то она сама понимает какой клиент на каком оффсете патриции остановился, в противном случае оффсет надо будет указывать самому.

0

01.07.2021

do not import flask 🇺🇦 · Accepted Answer

do not import flask 🇺🇦

тебе нужна consumer group которая будет хранить оффсеты

0

01.07.2021

170 похожих чатов

Добрый день Подскажите, пожалуйста, а как можно в библиотеке kafka-go пропустить

3 ответов

Похожие вопросы