Я пытаюсь перемотать потребительские смещения по теме назад на день назад. Я обнаружил, что когда я использую kafka-consumer-groups.sh --reset-offsets с параметром --to-datetime или --by-duration, результатом всегда являются последние смещения.
Некоторые эксперименты, которые я пробовал:
- Я создал новую группу потребителей. У новой группы потребителей наблюдаются те же симптомы.
- Я могу использовать --to-early, что возвращает его к самому раннему смещению, как и ожидалось. - Другие темы Я пробую это с работой нормально. Эта проблема, кажется, изолирована от одной темы.
Рассматриваемая тема kafka записывается приложением php с использованием библиотеки производителя weiboad / kafka-php. Это единственная тема в моих кластерах kafka, которая написана этой библиотекой. Все остальные темы в моем кластере, как и ожидалось, подчиняются стратегиям сброса по времени.
Мои вопросы:
Как стратегии сброса --to-datetime и --by-duration переводят время в значение смещения?
Что требует моя тема для использования этих функций, которых у нее явно нет? Или может быть эта тема чем-то коррумпирована?