Сохранение позиции чтения
Каждый писатель топика обладает позицией чтения.
С помощью команды topic consumer offset commit
можно сохранить позицию чтения добавленного ранее читателя.
Общий вид команды:
ydb [global options...] topic consumer offset commit [options...] <topic-path>
global options
— глобальные параметры.options
— параметры подкоманды.topic-path
— путь топика.
Посмотреть описание команды:
ydb topic consumer offset commit --help
Параметры подкоманды
Имя | Описание |
---|---|
--consumer <значение> |
Имя читателя. |
--partition <значение> |
Номер партиции. |
--offset <значение> |
Устанавливаемое значение смещения. |
Примеры
Примечание
В примерах используется профиль quickstart
, подробнее смотрите в Создание профиля для соединения с тестовой БД.
Установить для читателя с именем my-consumer
смещение 123456789 в топике my-topic
и партиции 1
:
ydb -p db1 topic consumer offset commit \
--consumer my-consumer \
--partition 1 \
--offset 123456789 \
my-topic