diff --git a/internal/callbacker/send_manager/send_manager.go b/internal/callbacker/send_manager/send_manager.go index 6831e7305..36c84f114 100644 --- a/internal/callbacker/send_manager/send_manager.go +++ b/internal/callbacker/send_manager/send_manager.go @@ -73,6 +73,10 @@ func WithNow(nowFunc func() time.Time) func(*SendManager) { func WithBufferSize(size int) func(*SendManager) { return func(m *SendManager) { + if size >= entriesBufferSize { + m.bufferSize = entriesBufferSize + return + } m.bufferSize = size } }