From cc795028eca7f91db0ddfe0f5265bd199fba86d4 Mon Sep 17 00:00:00 2001 From: Jorny Date: Wed, 13 Mar 2024 11:13:42 +0300 Subject: [PATCH 1/2] Change datastreams_proxy supported codec Change datastreams proxy supported codec --- ydb/services/datastreams/datastreams_proxy.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ydb/services/datastreams/datastreams_proxy.cpp b/ydb/services/datastreams/datastreams_proxy.cpp index 8b2e373acf28..5c3db7e9c614 100644 --- a/ydb/services/datastreams/datastreams_proxy.cpp +++ b/ydb/services/datastreams/datastreams_proxy.cpp @@ -121,7 +121,7 @@ namespace NKikimr::NDataStreams::V1 { topicRequest.mutable_retention_period()->set_seconds( TDuration::Hours(DEFAULT_STREAM_DAY_RETENTION).Seconds()); } - topicRequest.mutable_supported_codecs()->add_codecs(Ydb::Topic::CODEC_RAW); + topicRequest.mutable_supported_codecs()->add_codecs(Ydb::Topic::CODEC_GZIP); topicRequest.set_partition_write_speed_bytes_per_second( PartitionWriteSpeedInBytesPerSec(GetProtoRequest()->write_quota_kb_per_sec())); topicRequest.set_partition_write_burst_bytes( From e8fa9cc9fce4dfbf559377d059e53aeae45c9a97 Mon Sep 17 00:00:00 2001 From: Jornydb Date: Wed, 13 Mar 2024 11:38:48 +0300 Subject: [PATCH 2/2] Update datastreams_proxy supported codec --- ydb/services/datastreams/datastreams_proxy.cpp | 1 - 1 file changed, 1 deletion(-) diff --git a/ydb/services/datastreams/datastreams_proxy.cpp b/ydb/services/datastreams/datastreams_proxy.cpp index 5c3db7e9c614..11289cb4a001 100644 --- a/ydb/services/datastreams/datastreams_proxy.cpp +++ b/ydb/services/datastreams/datastreams_proxy.cpp @@ -121,7 +121,6 @@ namespace NKikimr::NDataStreams::V1 { topicRequest.mutable_retention_period()->set_seconds( TDuration::Hours(DEFAULT_STREAM_DAY_RETENTION).Seconds()); } - topicRequest.mutable_supported_codecs()->add_codecs(Ydb::Topic::CODEC_GZIP); topicRequest.set_partition_write_speed_bytes_per_second( PartitionWriteSpeedInBytesPerSec(GetProtoRequest()->write_quota_kb_per_sec())); topicRequest.set_partition_write_burst_bytes(