Closed JuanjoFuchs closed 4 years ago
I made a mistake, BoundedConcurrentQueue does not accept a negative queue limit. We need to use the default specified in PeriodicBatchingSinkOptions.QueueLimit
PeriodicBatchingSinkOptions.QueueLimit
PeriodicBatchingSinkOptions.cs#L45
I've noticed 100,000 is also the default used by ElasticSearchSink which also depends on the PeriodicBatchingSink
I made a mistake, BoundedConcurrentQueue does not accept a negative queue limit. We need to use the default specified in
PeriodicBatchingSinkOptions.QueueLimit
PeriodicBatchingSinkOptions.cs#L45