Skip to content

Commit bde7227

Browse files
fix log message
1 parent 4f69883 commit bde7227

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -362,7 +362,7 @@ private async Task RunProcessingStreamRequest()
362362
}
363363
catch (Exception e)
364364
{
365-
Logger.LogError(e, "ReaderSession[{SessionId}] have transport error on Write", SessionId);
365+
Logger.LogError(e, "ReaderSession[{SessionId}] have error on Write", SessionId);
366366

367367
ReconnectSession();
368368

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -495,7 +495,7 @@ public async Task Write(ConcurrentQueue<MessageSending> toSendBuffer)
495495
}
496496
catch (Exception e)
497497
{
498-
Logger.LogError(e, "WriterSession[{SessionId}] have transport error on Write, last SeqNo={SeqNo}",
498+
Logger.LogError(e, "WriterSession[{SessionId}] have error on Write, last SeqNo={SeqNo}",
499499
SessionId, Volatile.Read(ref _seqNum));
500500

501501
ReconnectSession();

0 commit comments

Comments
 (0)