Skip to content

Commit 33394b6

Browse files
fix
1 parent 1d9eb7a commit 33394b6

File tree

3 files changed

+2
-3
lines changed

3 files changed

+2
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ internal bool TryDequeueMessage([MaybeNullWhen(false)] out Message<TValue> messa
6666
partitionSessionId: _partitionSession.PartitionSessionId,
6767
producerId: _batch.ProducerId,
6868
createdAt: messageData.CreatedAt.ToDateTime(),
69-
metadata: messageData.MetadataItems.Select(item => new Sdk.Topic.Metadata(item.Key, item.Value.ToByteArray()))
69+
metadata: messageData.MetadataItems.Select(item => new Metadata(item.Key, item.Value.ToByteArray()))
7070
.ToImmutableArray(),
7171
seqNo: messageData.SeqNo,
7272
offsetsRange: new OffsetsRange

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ internal Message(
4747

4848
public DateTime CreatedAt { get; }
4949

50-
public IReadOnlyCollection<Sdk.Topic.Metadata> Metadata { get; }
50+
public IReadOnlyCollection<Metadata> Metadata { get; }
5151

5252
public long SeqNo { get; }
5353

src/Ydb.Sdk/test/Ydb.Sdk.Topic.Tests/SerializerDeserializerUnitTests.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
using Xunit;
2-
using Ydb.Sdk.Services.Topic;
32

43
namespace Ydb.Sdk.Topic.Tests;
54

0 commit comments

Comments
 (0)