Добавление читателя топика
С помощью команды topic consumer add вы можете добавить читателя для созданного ранее топика.
Общий вид команды:
ydb [global options...] topic consumer add [options...] <topic-path>
global options— глобальные параметры.options— параметры подкоманды.topic-path— путь топика.
Посмотрите описание команды добавления читателя:
ydb topic consumer add --help
Параметры подкоманды
| Имя | Описание |
|---|---|
--consumer VAL |
Имя читателя, которого нужно добавить. |
--starting-message-timestamp VAL |
Время в формате UNIX timestamp. Чтение начнется с первого сообщения, полученного после указанного времени. Если время не задано, то чтение начнется с самого старого сообщения в топике. |
--supported-codecs |
Поддерживаемые методы сжатия данных. Значение по умолчанию — raw.Возможные значения: |
Примеры
Примечание
В примерах используется профиль quickstart, подробнее смотрите в Создание профиля для соединения с тестовой БД.
Создайте читателя с именем my-consumer для созданного ранее топика my-topic, чтение начнется с первого сообщения, полученного после 15 августа 2022 13:00:00 GMT:
ydb -p quickstart topic consumer add \
--consumer my-consumer \
--starting-message-timestamp 1660568400 \
my-topic
Убедитесь, что читатель создан:
ydb -p quickstart 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 |
└──────────────┴─────────────────┴───────────────────────────────┴───────────┘