diff --git a/internal/topic/topicreadercommon/committer.go b/internal/topic/topicreadercommon/committer.go index 428fe7df6..e27ab6d6e 100644 --- a/internal/topic/topicreadercommon/committer.go +++ b/internal/topic/topicreadercommon/committer.go @@ -19,7 +19,7 @@ import ( var ( ErrCommitDisabled = xerrors.Wrap(errors.New("ydb: commits disabled")) - ErrWrongCommitOrderInSyncMode = xerrors.Wrap(errors.New("ydb: wrong commit order in sync mode")) + ErrWrongCommitOrderInSyncMode = xerrors.Wrap(errors.New("ydb: wrong commit order in sync mode. It means you skipped committing some messages. Out-of-order commits are OK for async mode - you can commit the messages later. But im sync mode, it means deadlock: the code waits for a commit ack from the server, but the server waits for the commits of the skipped message. In sync mode, ensure that you commit messages/batches in the same order as you read them")) //nolint:lll ) type SendMessageToServerFunc func(msg rawtopicreader.ClientMessage) error