fix

Author: nshestakov

ydb/core/kafka_proxy/kafka_messages_int.h

@@ -490,7 +490,7 @@ class TypeStrategy<Meta, TKafkaRecords, TKafkaRecordsDesc> {
  TKafkaRecordBatchV0 v0;
  v0.Read(readable, magic);
 
- value->Magic = magic;
+ value->Magic = 2;
  value->Attributes = v0.Record.Attributes & 0x07;
 
  value->Records.resize(1);

ydb/core/kafka_proxy/ut/ut_serialization.cpp

@@ -776,7 +776,7 @@ Y_UNIT_TEST(ProduceRequestData_Record_v0) {
  UNIT_ASSERT_EQUAL(r0.BaseOffset, 0);
  UNIT_ASSERT_EQUAL(r0.BatchLength, 0);
  UNIT_ASSERT_EQUAL(r0.PartitionLeaderEpoch, -1);
- UNIT_ASSERT_EQUAL(r0.Magic, 0);
+ UNIT_ASSERT_EQUAL(r0.Magic, 2);
  UNIT_ASSERT_EQUAL(r0.Crc, 544167206);
  UNIT_ASSERT_EQUAL(r0.Attributes, 0);
  UNIT_ASSERT_EQUAL(r0.LastOffsetDelta, 0);
@@ -826,7 +826,7 @@ Y_UNIT_TEST(ProduceRequestData_Record_v0_manyMessages) {
  UNIT_ASSERT_EQUAL(r0.BaseOffset, 0);
  UNIT_ASSERT_EQUAL(r0.BatchLength, 0);
  UNIT_ASSERT_EQUAL(r0.PartitionLeaderEpoch, -1);
- UNIT_ASSERT_EQUAL(r0.Magic, 0);
+ UNIT_ASSERT_EQUAL(r0.Magic, 2);
  UNIT_ASSERT_EQUAL(r0.Crc, 0);
  UNIT_ASSERT_EQUAL(r0.Attributes, 0);
  UNIT_ASSERT_EQUAL(r0.LastOffsetDelta, 0);