diff options
author | ilnaz <ilnaz@ydb.tech> | 2023-10-12 17:16:49 +0300 |
---|---|---|
committer | ilnaz <ilnaz@ydb.tech> | 2023-10-12 17:38:05 +0300 |
commit | e27b8a176337e927c312ba2c79e080bbb68b6734 (patch) | |
tree | f1c830d3bad12bd260b0af9540ff11371d47b13a | |
parent | 597e0411eb83650b79cf46d727e60211df316169 (diff) | |
download | ydb-e27b8a176337e927c312ba2c79e080bbb68b6734.tar.gz |
TOPIC_MIN_ACTIVE_PARTITIONS
4 files changed, 22 insertions, 0 deletions
diff --git a/ydb/docs/en/core/concepts/cdc.md b/ydb/docs/en/core/concepts/cdc.md index f395665fb9e..63b1c4a476c 100644 --- a/ydb/docs/en/core/concepts/cdc.md +++ b/ydb/docs/en/core/concepts/cdc.md @@ -226,6 +226,16 @@ Deleting records before they are processed by the client will cause [offset](top To set up the record retention period, specify the [RETENTION_PERIOD](../yql/reference/syntax/alter_table.md#changefeed-options) parameter when creating a changefeed. +## Topic partitions {#topic-partitions} + +By default, the number of [topic partitions](topic.md#partitioning) is equal to the number of table partitions. The number of topic partitions can be redefined by specifying [TOPIC_MIN_ACTIVE_PARTITIONS](../yql/reference/syntax/alter_table.md#changefeed-options) parameter when creating a changefeed. + +{% note info %} + +Currently, the ability to explicitly specify the number of topic partitions is available only for tables whose first primary key component is of type `Uint64` or `Uint32`. + +{% endnote %} + ## Creating and deleting a changefeed {#ddl} You can add a changefeed to an existing table or erase it using the [ADD CHANGEFEED and DROP CHANGEFEED](../yql/reference/syntax/alter_table.md#changefeed) directives of the YQL `ALTER TABLE` statement. When erasing a table, the changefeed added to it is also deleted. diff --git a/ydb/docs/en/core/yql/reference/yql-core/syntax/_includes/alter_table.md b/ydb/docs/en/core/yql/reference/yql-core/syntax/_includes/alter_table.md index e10ac43abb1..f0cb8363b26 100644 --- a/ydb/docs/en/core/yql/reference/yql-core/syntax/_includes/alter_table.md +++ b/ydb/docs/en/core/yql/reference/yql-core/syntax/_includes/alter_table.md @@ -88,6 +88,7 @@ ALTER TABLE `series` RENAME INDEX `title_index` TO `title_index_new`; {% endif %} * `VIRTUAL_TIMESTAMPS`: Enabling/disabling [virtual timestamps](../../../../concepts/cdc#virtual-timestamps). Disabled by default. * `RETENTION_PERIOD`: [Record retention period](../../../../concepts/cdc#retention-period). The value type is `Interval` and the default value is 24 hours (`Interval('PT24H')`). +* `TOPIC_MIN_ACTIVE_PARTITIONS`: [The number of topic partitions](../../../../concepts/cdc#topic-partitions). By default, the number of topic partitions is equal to the number of table partitions. * `INITIAL_SCAN`: Enables/disables [initial table scan](../../../../concepts/cdc#initial-scan). Disabled by default. {% if audience == "tech" %} * `AWS_REGION`: Value to be written to the `awsRegion` field. Used only with the `DYNAMODB_STREAMS_JSON` format. diff --git a/ydb/docs/ru/core/concepts/cdc.md b/ydb/docs/ru/core/concepts/cdc.md index 75b5298901d..ad46724528d 100644 --- a/ydb/docs/ru/core/concepts/cdc.md +++ b/ydb/docs/ru/core/concepts/cdc.md @@ -226,6 +226,16 @@ Change Data Capture (CDC) обеспечивает захват изменени Для настройки времени хранения записей укажите параметр [RETENTION_PERIOD](../yql/reference/syntax/alter_table.md#changefeed-options) при создании потока изменений. +## Количество партиций топика {#topic-partitions} + +По умолчанию количество [партиций топика](topic.md#partitioning) равно количеству партиций таблицы. Количество партиций топика можно переопределить, указав параметр [TOPIC_MIN_ACTIVE_PARTITIONS](../yql/reference/syntax/alter_table.md#changefeed-options) при создании потока изменений. + +{% note info %} + +В настоящий момент возможность явного указания числа партиций топика доступна только для таблиц, у которых первый компонент первичного ключа имеет тип `Uint64` или `Uint32`. + +{% endnote %} + ## Создание и удаление потока изменений {#ddl} Поток изменений может быть добавлен к существующей таблице или удален директивами [ADD CHANGEFEED и DROP CHANGEFEED](../yql/reference/syntax/alter_table.md#changefeed) операции YQL `ALTER TABLE`. При удалении таблицы добавленный к ней поток изменений также будет удален. diff --git a/ydb/docs/ru/core/yql/reference/yql-core/syntax/_includes/alter_table.md b/ydb/docs/ru/core/yql/reference/yql-core/syntax/_includes/alter_table.md index d892fe9bb45..69432371cc7 100644 --- a/ydb/docs/ru/core/yql/reference/yql-core/syntax/_includes/alter_table.md +++ b/ydb/docs/ru/core/yql/reference/yql-core/syntax/_includes/alter_table.md @@ -88,6 +88,7 @@ ALTER TABLE `series` RENAME INDEX `title_index` TO `title_index_new`; {% endif %} * `VIRTUAL_TIMESTAMPS` — включение-выключение [виртуальных меток времени](../../../../concepts/cdc#virtual-timestamps). По умолчанию выключено. * `RETENTION_PERIOD` — [время хранения записей](../../../../concepts/cdc#retention-period). Тип значения — `Interval`, значение по умолчанию — 24 часа (`Interval('PT24H')`). +* `TOPIC_MIN_ACTIVE_PARTITIONS` — [количество партиций топика](../../../../concepts/cdc#topic-partitions). По умолчанию количество партиций топика равно количеству партиций таблицы. * `INITIAL_SCAN` — включение-выключение [первоначального сканирования](../../../../concepts/cdc#initial-scan) таблицы. По умолчанию выключено. {% if audience == "tech" %} * `AWS_REGION` — значение, которое будет записано в поле `awsRegion`. Применимо только совместно с форматом `DYNAMODB_STREAMS_JSON`. |