Merge 587ca40 into f2805c6

ydb-platform · Oct 4, 2024 · b59922a · b59922a
2 parents f2805c6 + 587ca40
commit b59922a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp b/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
@@ -262,6 +262,7 @@ THolder<TEvPartitionWriter::TEvWriteRequest> Convert(const TProduceRequestData::
 
     for (const auto& record : batch->Records) {
         NKikimrPQClient::TDataChunk proto;
+        proto.set_codec(NPersQueueCommon::RAW);
         for(auto& h : record.Headers) {
                 auto res = proto.AddMessageMeta();
             if (h.Key) {