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

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

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

3 ответов

6 просмотров

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

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

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

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

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

Обсуждают сегодня

А чем вам питонисты не угодили?😂
.
79
Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
75
Ребят, а за скок можно впарить анон чат с апишкой и веб админкой ?
Eugene Неелов
15
Ещё такой вопрос. Мне необходимо хранить пароль пользователя локально. Для этого планирую использовать ini файл. Это для автозаполнения полей логин и пароль при авторизации. Е...
Евгений
19
Anyone knows how to build this widget in Flutter? I have all the assets for round stations and the road, but how can I make the my widget animate between these stations? And h...
Mohammad Zamani
9
короче я не выдержал постоянно определять структуры, чтобы возвращать массивы разных типов. Как обычно еще это делают?
Павλо 🇺🇦
7
Если у очереди установлено x-message-ttl, при получении сообщения из этой очереди, можно узнать остаток времени жизни сообщения?
Сергей
8
Подскажите как мне лучше держать websocket сединение и переодически передавать в него данные? Сначала я сделал так: for _ in 1...1000 { try? await ws.send("test") try...
Mihail Verenich
2
Ты просто гитлеровскую эстетику плохо понимаешь. Он же всё под Цезаря делал. А это как бы запрещённый приём в политике. Пиджаки они зачем все носят? Чтобы показать что они тип...
Ivan Kropotkin
4
А цены чем оправданы?
Lencore
7
Карта сайта