пишутся данные каждую секунду и сразу читаются, чтение происходит быстрее. Выключаем одну ноду так чтобы она выпала из кластера по таймауту, на время выключения данные продолжали прилетать на две другие ноды. Возращаем выключенную ноду и на неё прилетает запрос на чтение по смещению которое уже давно не в диапазоне старых данных
этой ноды, т.е синхронизации данных ещё не произошло. Синхронизация данных и смещения происходит при записи в эту ноду. Вопрос можно ли както сказать кафке чтобы она заблокировала чтение до синхронизации ноды в кластере с другими нодами ? единственно решение которое пришло в голову это не отдать данные потому что их нету, но если при чтении стоит offsetReseting и мы читаем за диапазоном произойдет сброс на begin или end а я как раз использую такие настройки чтобы переходить к первому живому сегменту.
Мужики а по моей кляузе чонибудь черканите, да - нет - свой ответ ?
А можно чуть полнее описать какую проблему вы решаете?
Обсуждают сегодня