From 545e0fd8d059c88574154897fc346ede22f0f33d Mon Sep 17 00:00:00 2001 From: dongmen <414110582@qq.com> Date: Fri, 8 Nov 2024 17:42:11 +0800 Subject: [PATCH] dispatcher: disable batch Signed-off-by: dongmen <414110582@qq.com> --- downstreamadapter/dispatcher/helper.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/downstreamadapter/dispatcher/helper.go b/downstreamadapter/dispatcher/helper.go index 2f0908f4..badba4dc 100644 --- a/downstreamadapter/dispatcher/helper.go +++ b/downstreamadapter/dispatcher/helper.go @@ -343,7 +343,7 @@ func GetEventDynamicStream() dynstream.DynamicStream[common.GID, common.Dispatch if eventDynamicStream == nil { eventDynamicStreamOnce.Do(func() { option := dynstream.NewOption() - option.BatchCount = 128 + //option.BatchCount = 128 // Enable memory control for dispatcher events dynamic stream. log.Info("New EventDynamicStream, memory control is enabled") option.EnableMemoryControl = true