diff options
| author | ilnaz <ilnaz@ydb.tech> | 2022-09-11 18:29:37 +0300 |
|---|---|---|
| committer | ilnaz <ilnaz@ydb.tech> | 2022-09-11 18:29:37 +0300 |
| commit | aded432c3c4095914d3e0a76a330aa49d288e0f8 (patch) | |
| tree | 62501a39df1a8eb7b577c6bcc047e173c865f700 | |
| parent | 1547a3cfd895eb286459585b239089c4deaf4288 (diff) | |
| download | ydb-aded432c3c4095914d3e0a76a330aa49d288e0f8.tar.gz | |
CDC topic settings
| -rw-r--r-- | ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp index ae1bab311e8..e7d71e72135 100644 --- a/ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp @@ -667,6 +667,8 @@ TVector<ISubOperationBase::TPtr> CreateNewCdcStream(TOperationId opId, const TTx auto& partitionConfig = *pqConfig.MutablePartitionConfig(); partitionConfig.SetLifetimeSeconds(retentionPeriod.Seconds()); + partitionConfig.SetWriteSpeedInBytesPerSecond(1_MB); // TODO: configurable write speed + partitionConfig.SetBurstSize(1_MB); // TODO: configurable burst for (const auto& tag : table->KeyColumnIds) { Y_VERIFY(table->Columns.contains(tag)); |