removed flag part from the pr

Author: rekby

CHANGELOG.md

@@ -1,5 +1,4 @@
 * Allowed overflow queue limit for one goroutine at time for topic writer
-* Added option WithReaderDisableSplitMergePartitionsSupport for topic reader
 
 ## v3.105.2
 * Improved the `ydb.WithSessionPoolSessionUsageLimit` option for allow `time.Duration` as argument type for limit max session time to live since create time 

internal/topic/topiclistenerinternal/stream_listener.go

@@ -174,7 +174,7 @@ func (l *streamListener) initStream(ctx context.Context, client TopicClient) err
 	}
 	l.stream = topicreadercommon.NewSyncedStream(stream)
 
-	initMessage := topicreadercommon.CreateInitMessage(l.cfg.Consumer, false, l.cfg.Selectors)
+	initMessage := topicreadercommon.CreateInitMessage(l.cfg.Consumer, l.cfg.Selectors)
 	err = stream.Send(initMessage)
 	if err != nil {
 		return xerrors.WithStackTrace(fmt.Errorf("ydb: failed to send init request for read stream in the listener: %w", err))

internal/topic/topicreadercommon/init_message.go

@@ -2,14 +2,10 @@ package topicreadercommon
 
 import "github.com/ydb-platform/ydb-go-sdk/v3/internal/grpcwrapper/rawtopic/rawtopicreader"
 
-func CreateInitMessage(
-	consumer string,
-	supportAutoPartition bool,
-	selectors []*PublicReadSelector,
-) *rawtopicreader.InitRequest {
+func CreateInitMessage(consumer string, selectors []*PublicReadSelector) *rawtopicreader.InitRequest {
 	res := &rawtopicreader.InitRequest{
 		Consumer:                consumer,
-		AutoPartitioningSupport: supportAutoPartition,
+		AutoPartitioningSupport: true,
 	}
 
 	res.TopicsReadSettings = make([]rawtopicreader.TopicReadSettings, len(selectors))

internal/topic/topicreaderinternal/stream_reader_impl.go

@@ -80,7 +80,6 @@ type topicStreamReaderConfig struct {
 	GetPartitionStartOffsetCallback PublicGetPartitionStartOffsetFunc
 	CommitMode                      topicreadercommon.PublicCommitMode
 	Decoders                        topicreadercommon.DecoderMap
-	DisableSplitMergeSupport        bool
 }
 
 func newTopicStreamReaderConfig() topicStreamReaderConfig {
@@ -612,8 +611,7 @@ func (r *topicStreamReaderImpl) setStarted() error {
 }
 
 func (r *topicStreamReaderImpl) initSession() (err error) {
-	supportAutoPartition := !r.cfg.DisableSplitMergeSupport
-	initMessage := topicreadercommon.CreateInitMessage(r.cfg.Consumer, supportAutoPartition, r.cfg.ReadSelectors)
+	initMessage := topicreadercommon.CreateInitMessage(r.cfg.Consumer, r.cfg.ReadSelectors)
 
 	onDone := trace.TopicOnReaderInit(r.cfg.Trace, r.readConnectionID, initMessage)
 	defer func() {

topic/topicoptions/topicoptions_reader.go

@@ -281,11 +281,3 @@ func WithReaderWithoutConsumer(saveStateOnReconnection bool) ReaderOption {
 		cfg.CommitMode = CommitModeNone
 	}
 }
-
-// WithReaderDisableSplitMergePartitionsSupport turn off support split-merge reorder messages
-// on client side.
-func WithReaderDisableSplitMergePartitionsSupport(disableSupport bool) ReaderOption {
-	return func(cfg *topicreaderinternal.ReaderConfig) {
-		cfg.DisableSplitMergeSupport = disableSupport
-	}
-}