Я столкнулся с проблемой в потребителе кафки для обработки исключений.Мой поток: 1) подписаться на потребителя kafka 2) опрос назначить карте буфера 3) зафиксировать (поскольку процесс занимает больше времени ожидания сеанса, фиксируя потребителя перед обработкой) 4) обработать загрузку карты буфера в базе данных 5) если естьИсключение в шаге обработки 4: поиск исходного номера смещения, сохраненного в шаге опроса 2
Существуют две проблемы: поиск не работает из исключения. Когда я снова запускаю пользователя с опцией поиска, я создаю один поиск клиента.это к предыдущему успешному смещению, я подтвердил, что поиск движется правильно.Затем я создал еще одного потребителя kafka для обработки данных, но операция поиска не рассматривается, она выбирается из зафиксированного смещения.