FFORGE//RS
← Маршрут

distributed systems / УРОВЕНЬ 5

Отозванный consumer закоммитил последним

ОЦЕНКА60 МИН
01

ТЕОРИЯ / ВОСПРОИЗВЕДЕНИЕ

Что нужно восстановить

  • Различать fetched/committed/completed и fence stale completions generation epoch

Revoke закрывает admission, а tombstone сохраняет epoch

In-flight work дренируется или отменяется per partition. Completion принимается только от current generation и exact offset; Kafka commit хранит следующий offset. Tombstone не позволяет delayed callback стать свежим после revoke.

КОНТРОЛЬНАЯ ТОЧКА

Что входит в безопасный handoff partition при detached handler?

Выберите все подходящие варианты. Ответ засчитывается только при точном совпадении набора.

ISOLATED RUST 1.96
src/lib.rsРЕДАКТИРОВАНИЕ

02 / ОТЛАДКА

Найдите и исправьте дефект

Исправьте `RebalanceGate`: validate positions/generations, stale revoke не снимает new owner, одна in-flight record per partition, replay/uncommittable не стартуют, completion match generation+offset перед `offset+1`.

Инициализация редактора…
ОБЛАЧНЫЙ SANDBOXсеть выключена · 256 МБ · 12 с
3 / 64 KB
ВЫВОД
Runner ждёт отправки кода.