File tree 1 file changed +2
-2
lines changed
ydb/core/kafka_proxy/actors
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 16
16
namespace NKafka {
17
17
18
18
static constexpr size_t SizeOfZeroVarint = 1 ;
19
- static constexpr size_t BatchFirstTwoFildsSize = 12 ;
19
+ static constexpr size_t BatchFirstTwoFieldsSize = 12 ;
20
20
static constexpr size_t KafkaMagic = 2 ;
21
21
22
22
NActors::IActor* CreateKafkaFetchActor (const TContext::TPtr context, const ui64 correlationId, const TMessagePtr<TFetchRequestData>& message) {
@@ -186,7 +186,7 @@ void TKafkaFetchActor::FillRecordsBatch(const NKikimrClient::TPersQueueFetchResp
186
186
recordsBatch.BaseSequence = baseSequense;
187
187
// recordsBatch.Attributes https://kafka.apache.org/documentation/#recordbatch
188
188
189
- recordsBatch.BatchLength = recordsBatch.Size (TKafkaRecordBatch::MessageMeta::PresentVersions.Max ) - BatchFirstTwoFildsSize ;
189
+ recordsBatch.BatchLength = recordsBatch.Size (TKafkaRecordBatch::MessageMeta::PresentVersions.Max ) - BatchFirstTwoFieldsSize ;
190
190
KAFKA_LOG_D (" Fetch actor: RecordBatch info. BaseOffset: " << recordsBatch.BaseOffset << " , LastOffsetDelta: " << recordsBatch.LastOffsetDelta <<
191
191
" , BaseTimestamp: " << recordsBatch.BaseTimestamp << " , MaxTimestamp: " << recordsBatch.MaxTimestamp <<
192
192
" , BaseSequence: " << recordsBatch.BaseSequence << " , BatchLength: " << recordsBatch.BatchLength );
You can’t perform that action at this time.
0 commit comments