fix compile and linter errors

Author: rekby

CHANGELOG.md

@@ -1,3 +1,5 @@
+* Added Flush method for topic writer
+
 ## v3.66.0
 * Added experimental package `retry/budget` for limit second and subsequent retry attempts 
 * Refactored internals for enabling `containedctx` linter

internal/topic/topicwriterinternal/queue.go

@@ -326,6 +326,7 @@ func (q *messageQueue) WaitLastWritten(ctx context.Context) error {
 	q.m.WithRLock(func() {
 		lastIndex = q.lastWrittenIndex
 	})
+
 	return q.Wait(ctx, MessageQueueAckWaiter{sequenseNumbers: []int{lastIndex}})
 }
 

internal/topic/topicwriterinternal/writer_reconnector_test.go

@@ -554,7 +554,11 @@ func TestWriterImpl_CloseWithFlush(t *testing.T) {
 
 	closeCompleted := make(empty.Chan)
 	go func() {
-		err := e.writer.Write(e.ctx, []Message{{SeqNo: seqNo, CreatedAt: messageTime, Data: bytes.NewReader(messageData)}})
+		err := e.writer.Write(e.ctx, []PublicMessage{{
+			SeqNo:     seqNo,
+			CreatedAt: messageTime,
+			Data:      bytes.NewReader(messageData),
+		}})
 		close(writeCompleted)
 		require.NoError(t, err)
 	}()