We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1de93de commit 4a88496Copy full SHA for 4a88496
ydb/core/kafka_proxy/actors/kafka_fetch_actor.cpp
@@ -174,7 +174,7 @@ void TKafkaFetchActor::FillRecordsBatch(const NKikimrClient::TPersQueueFetchResp
174
record.TimestampDelta = lastTimestamp - baseTimestamp;
175
176
record.Length = record.Size(TKafkaRecord::MessageMeta::PresentVersions.Max) - SizeOfZeroVarint;
177
- KAFKA_LOG_D("Fetch actor: Record info. Value: " << record.DataChunk.GetData() << ", OffsetDelta: " << record.OffsetDelta <<
+ KAFKA_LOG_D("Fetch actor: Record info. OffsetDelta: " << record.OffsetDelta <<
178
", TimestampDelta: " << record.TimestampDelta << ", Length: " << record.Length);
179
}
180
0 commit comments