Добавление читателя топика

С помощью команды topic consumer add вы можете добавить читателя для созданного ранее топика.

Общий вид команды:

ydb [global options...] topic consumer add [options...] <topic-path>

Посмотрите описание команды добавления читателя:

ydb topic consumer add --help

Параметры подкоманды

Имя Описание
--consumer VAL Имя читателя, которого нужно добавить.
--starting-message-timestamp VAL Время в формате UNIX timestamp. Чтение начнется с первого сообщения, полученного после указанного времени. Если время не задано, то чтение начнется с самого старого сообщения в топике.

Примеры

Примечание

В примерах используется профиль db1, подробнее смотрите в Создание профиля соединения.

Создайте читателя с именем my-consumer для созданного ранее топика my-topic, чтение начнется с первого сообщения, полученного после 15 августа 2022 13:00:00 GMT:

ydb -p db1 topic consumer add \
  --consumer my-consumer \
  --starting-message-timestamp 1660568400 \
  my-topic 

Убедитесь, что читатель создан:

ydb -p db1 scheme describe my-topic

Результат:

RetentionPeriod: 2 hours
PartitionsCount: 2
SupportedCodecs: RAW, GZIP

Consumers: 
┌──────────────┬─────────────────┬───────────────────────────────┬───────────┐
| ConsumerName | SupportedCodecs | ReadFrom                      | Important |
├──────────────┼─────────────────┼───────────────────────────────┼───────────┤
| my-consumer  | RAW, GZIP       | Mon, 15 Aug 2022 16:00:00 MSK | 0         |
└──────────────┴─────────────────┴───────────────────────────────┴───────────┘