dev: Added SeqNo to Ydb.Sdk.Services.Topic.Reader.Message

Author: KirillKurdyukov

CHANGELOG.md

@@ -1,3 +1,5 @@
+- Added SeqNo to `Ydb.Sdk.Services.Topic.Reader.Message`.
+
 ## v0.15.2
 - Added SeqNo to `WriteResult`.
 - Changed signature of the `TopicClient.DropTopic` method.

src/Ydb.Sdk/src/Services/Topic/Reader/InternalBatchMessages.cs

@@ -68,6 +68,7 @@ internal bool TryDequeueMessage([MaybeNullWhen(false)] out Message<TValue> messa
             createdAt: messageData.CreatedAt.ToDateTime(),
             metadata: messageData.MetadataItems.Select(item => new Metadata(item.Key, item.Value.ToByteArray()))
                 .ToImmutableArray(),
+            seqNo: messageData.SeqNo,
             offsetsRange: new OffsetsRange
                 { Start = _partitionSession.PrevEndOffsetMessage, End = nextCommitedOffset },
             readerSession: _readerSession

src/Ydb.Sdk/src/Services/Topic/Reader/Message.cs

@@ -17,6 +17,7 @@ internal Message(
         string producerId,
         DateTime createdAt,
         ImmutableArray<Metadata> metadata,
+        long seqNo,
         OffsetsRange offsetsRange,
         ReaderSession<TValue> readerSession)
     {
@@ -26,6 +27,7 @@ internal Message(
         ProducerId = producerId;
         CreatedAt = createdAt;
         Metadata = metadata;
+        SeqNo = seqNo;
 
         _partitionSessionId = partitionSessionId;
         _offsetsRange = offsetsRange;
@@ -47,6 +49,8 @@ internal Message(
 
     public IReadOnlyCollection<Metadata> Metadata { get; }
 
+    public long SeqNo { get; }
+
     public Task CommitAsync()
     {
         return _readerSession.CommitOffsetRange(_offsetsRange, _partitionSessionId);