File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
src/Ydb.Sdk/src/Services/Topic/Reader Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -598,16 +598,14 @@ internal void RegisterCommitRequest(CommitSending commitSending)
598598 }
599599 }
600600
601- internal int HandleCommitedOffset ( long commitedOffset )
601+ internal void HandleCommitedOffset ( long commitedOffset )
602602 {
603603 if ( CommitedOffset >= commitedOffset )
604604 {
605605 _logger . LogError (
606- "Received CommitOffsetResponse[CommitedOffset={CommitedOffset}] " +
606+ "PartitionSession[{PartitionSessionId}] received CommitOffsetResponse[CommitedOffset={CommitedOffset}] " +
607607 "which is not greater than previous committed offset: {PrevCommitedOffset}" ,
608- commitedOffset , CommitedOffset ) ;
609-
610- return 0 ;
608+ PartitionSessionId , commitedOffset , CommitedOffset ) ;
611609 }
612610
613611 CommitedOffset = commitedOffset ;
You can’t perform that action at this time.
0 commit comments