We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 47bedc0 commit 1738d8cCopy full SHA for 1738d8c
ydb/core/kafka_proxy/actors/kafka_produce_actor.cpp
@@ -5,6 +5,7 @@
5
6
#include <ydb/core/persqueue/utils.h>
7
#include <ydb/core/protos/grpc_pq_old.pb.h>
8
+#include <ydb/public/api/protos/draft/persqueue_common.pb.h>
9
10
namespace NKafka {
11
@@ -262,6 +263,7 @@ THolder<TEvPartitionWriter::TEvWriteRequest> Convert(const TProduceRequestData::
262
263
264
for (const auto& record : batch->Records) {
265
NKikimrPQClient::TDataChunk proto;
266
+ proto.set_codec(NPersQueueCommon::RAW);
267
for(auto& h : record.Headers) {
268
auto res = proto.AddMessageMeta();
269
if (h.Key) {
0 commit comments