Skip to content

Commit 2b17e21

Browse files
fix
1 parent 3ab99a9 commit 2b17e21

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -98,9 +98,9 @@ public async Task<WriteResult> WriteAsync(Message<TValue> message, CancellationT
9898
continue;
9999
}
100100

101-
// _logger.LogWarning(
102-
// "Buffer overflow: the data size [{DataLength}] exceeds the current buffer limit ({CurLimitBufferSize}) [BufferMaxSize = {BufferMaxSize}]",
103-
// data.Length, curLimitBufferSize, _config.BufferMaxSize);
101+
_logger.LogWarning(
102+
"Buffer overflow: the data size [{DataLength}] exceeds the current buffer limit ({CurLimitBufferSize}) [BufferMaxSize = {BufferMaxSize}]",
103+
data.Length, curLimitBufferSize, _config.BufferMaxSize);
104104

105105
try
106106
{

src/Ydb.Sdk/tests/Topic/WriterIntegrationTests.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,8 @@ public async Task WriteAsync_When1000Messages_ReturnWriteResultIsPersisted()
6161
topicSettings.Consumers.Add(new Consumer("Consumer"));
6262
await topicClient.CreateTopic(topicSettings);
6363

64-
using var writer = new WriterBuilder<int>(_driver, topicName) { ProducerId = "producerId" }.Build();
64+
using var writer = new WriterBuilder<int>(_driver, topicName)
65+
{ ProducerId = "producerId", BufferMaxSize = 2000 }.Build();
6566

6667
var tasks = new List<Task>();
6768
for (var i = 0; i < messageCount; i++)

0 commit comments

Comments
 (0)