У меня работает потребитель kafka с тестом группы потребителей, в котором содержится 500 сообщений от пользователя из раздела 0. Теперь я не хочу менять группу потребителей, но я хочу, чтобы мой потребитель снова использовал 1-е сообщение. Я сбросил смещение на сервере. Но клиент снова сбрасывает смещения до 500+ и не потребляет от 1. Но это работает, если я остановлю потребителя и сброслю смещение на сервере, а затем остановлю потребителя.
Можно ли как-то компенсировать смещение без перезагрузки потребителя?