fix integration test (#1879)

Co-authored-by: Klepov Alex <aklepov@rutube.ru>

Author: xelavopelk

CHANGELOG.md

@@ -1,3 +1,5 @@
+Fixed race in integration test `TestTopicWriterLogMessagesWithoutData` 
+
 ## v3.117.0
 * Fixed `conn/pool.Get()` behaviour for YDB databases with public IPs. Bug was introduced in v3.116.2
 * Added helper methods `log.WithFields` and `log.FieldsFromContext` for working with structured logging fields via context.

tests/integration/topic_read_writer_test.go

@@ -27,6 +27,7 @@ import (
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/version"
 	"github.com/ydb-platform/ydb-go-sdk/v3/log"
 	xtest "github.com/ydb-platform/ydb-go-sdk/v3/pkg/xtest"
+	tu "github.com/ydb-platform/ydb-go-sdk/v3/testutil"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicoptions"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topicsugar"
 	"github.com/ydb-platform/ydb-go-sdk/v3/topic/topictypes"
@@ -44,7 +45,7 @@ func TestTopicWriterLogMessagesWithoutData(t *testing.T) {
 	metaKey := "gyoeexiufo"
 	metaValue := "fjedeikeosbv"
 
-	logs := &strings.Builder{}
+	logs := &tu.ThreadSafeBuilder{}
 	writer, err := scope.Driver().Topic().StartWriter(
 		scope.TopicPath(),
 		topicoptions.WithWriterProducerID(producerID),

testutil/thread_safe_builder.go

@@ -0,0 +1,38 @@
+package testutil
+
+import (
+	"strings"
+	"sync"
+)
+
+type ThreadSafeBuilder struct {
+	mu sync.Mutex
+	b  strings.Builder
+}
+
+func (tsb *ThreadSafeBuilder) WriteString(s string) (int, error) {
+	tsb.mu.Lock()
+	defer tsb.mu.Unlock()
+
+	return tsb.b.WriteString(s)
+}
+
+func (tsb *ThreadSafeBuilder) Write(p []byte) (int, error) {
+	tsb.mu.Lock()
+	defer tsb.mu.Unlock()
+
+	return tsb.b.Write(p)
+}
+
+func (tsb *ThreadSafeBuilder) String() string {
+	tsb.mu.Lock()
+	defer tsb.mu.Unlock()
+
+	return tsb.b.String()
+}
+
+func (tsb *ThreadSafeBuilder) Reset() {
+	tsb.mu.Lock()
+	defer tsb.mu.Unlock()
+	tsb.b.Reset()
+}