По умолчанию KStreams поддерживает два возможных значения для auto.offset.reset
. Это может быть либо " самое раннее ", либо " самое последнее ". Вы не можете установить конкретное смещение в коде приложения.
Во время сброса приложения есть опция. Если вы используете скрипт сброса приложения, вы можете использовать свойство --to-offset
и назначить его для определенного смещения. Приложение вернется к этой точке.
<path-to-confluent>/bin/kafka-streams-application-reset --application-id app1 --input-topics a,b --to-offset 1000
Подробности можно найти в документации:
https://docs.confluent.io/5.1.2/streams/developer-guide/app-reset-tool.html
В случае, если вы исправляете ошибки, онобудет лучше вернуться в самое раннее состояние, если это возможно.