File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed
ydb/services/persqueue_v1/actors Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -1729,7 +1729,6 @@ i64 TFormedReadResponse<TServerMessage>::ApplyResponse(TServerMessage&& resp) {
1729
1729
auto * partition_data = resp.mutable_data_batch ()->mutable_partition_data (0 );
1730
1730
Y_ABORT_UNLESS (partition_data != nullptr && partition_data->batches_size () > 0 );
1731
1731
1732
- // Проходим по всем батчам и устанавливаем codec в 0, если он равен -1
1733
1732
for (auto & batch : *partition_data->mutable_batches ()) {
1734
1733
for (auto & message_data : *batch.mutable_message_data ()) {
1735
1734
if (message_data.codec () == Ydb::PersQueue::V1::CODEC_UNSPECIFIED) {
@@ -1743,7 +1742,6 @@ i64 TFormedReadResponse<TServerMessage>::ApplyResponse(TServerMessage&& resp) {
1743
1742
auto * partition_data = resp.mutable_read_response ()->mutable_partition_data (0 );
1744
1743
Y_ABORT_UNLESS (partition_data != nullptr && partition_data->batches_size () > 0 );
1745
1744
1746
- // Проходим по всем батчам и устанавливаем codec в 0, если он равен -1
1747
1745
for (auto & batch : *partition_data->mutable_batches ()) {
1748
1746
if (batch.codec () == Ydb::Topic::CODEC_UNSPECIFIED) {
1749
1747
batch.set_codec (Ydb::Topic::CODEC_RAW);
You can’t perform that action at this time.
0 commit comments