From 25eb91de236c33f7dc691cecff9eb32a6a46d480 Mon Sep 17 00:00:00 2001
From: Nikita Saveliev <savnik@ydb.tech>
Date: Thu, 3 Oct 2024 09:33:51 +0000
Subject: [PATCH 1/3] Fix kafka produce codec

---
 ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp b/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
index 062e74853a18..6e44c49c4072 100644
--- 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(Ydb::Topic::CODEC_RAW);
         for(auto& h : record.Headers) {
                 auto res = proto.AddMessageMeta();
             if (h.Key) {

From 587ca405c6275331c94a0903b6467d25184609a5 Mon Sep 17 00:00:00 2001
From: Nikita Saveliev <savnik@ydb.tech>
Date: Fri, 4 Oct 2024 09:44:55 +0000
Subject: [PATCH 2/3] Fix codec enum

---
 ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp b/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
index 6e44c49c4072..d9e0fd877238 100644
--- a/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
+++ b/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
@@ -262,7 +262,7 @@ THolder<TEvPartitionWriter::TEvWriteRequest> Convert(const TProduceRequestData::
 
     for (const auto& record : batch->Records) {
         NKikimrPQClient::TDataChunk proto;
-        proto.set_codec(Ydb::Topic::CODEC_RAW);
+        proto.set_codec(NPersQueueCommon::RAW);
         for(auto& h : record.Headers) {
                 auto res = proto.AddMessageMeta();
             if (h.Key) {

From 193eaaa5b5f67d4103f21b3eb59f02516713fdf0 Mon Sep 17 00:00:00 2001
From: Nikita Saveliev <savnik@ydb.tech>
Date: Fri, 4 Oct 2024 12:02:16 +0000
Subject: [PATCH 3/3] Fix include

---
 ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp b/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
index d9e0fd877238..3f7d50f7dc58 100644
--- a/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
+++ b/ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
@@ -5,6 +5,7 @@
 
 #include <ydb/core/persqueue/utils.h>
 #include <ydb/core/protos/grpc_pq_old.pb.h>
+#include <ydb/public/api/protos/draft/persqueue_common.pb.h>
 
 namespace NKafka {