increase processor num

lidezhu · lidezhu · commit 2a8bdbb5de54 · 2024-10-15T10:42:54.000+08:00
diff --git a/logservice/eventstore/event_store.go b/logservice/eventstore/event_store.go
@@ -166,7 +166,7 @@ func New(
 ) EventStore {
 	clientConfig := &logpuller.SubscriptionClientConfig{
 		RegionRequestWorkerPerStore:   16,
-		ChangeEventProcessorNum:       32,
+		ChangeEventProcessorNum:       128,
 		AdvanceResolvedTsIntervalInMs: 600,
 	}
 	client := logpuller.NewSubscriptionClient(

Original file line number	Diff line number	Diff line change
`@@ -166,7 +166,7 @@ func New(`
`166`	`166`	`) EventStore {`
`167`	`167`	`clientConfig := &logpuller.SubscriptionClientConfig{`
`168`	`168`	`RegionRequestWorkerPerStore: 16,`
`169`		`- ChangeEventProcessorNum: 32,`
	`169`	`+ ChangeEventProcessorNum: 128,`
`170`	`170`	`AdvanceResolvedTsIntervalInMs: 600,`
`171`	`171`	`}`
`172`	`172`	`client := logpuller.NewSubscriptionClient(`