Ошибка производителя Kafka → System.InvalidOperationException ⇐ C#

[Anonymous]

Итак, я отправляю около 300 записей каждые 3 секунды и вижу сообщение об ошибке:
System.InvalidOperation: Не удалось создать поток: слишком большой результат (#)
в Confluent.Kafka.ProducerBuilder` 2.Build()
Я считаю, что это вызвано тем, что в очереди слишком много сообщений. Есть ли способ решить эту проблему?
Фрагмент кода:
await producerBuilder(topic,new Message)
.ContinueWith(
task => {
if(task.IsFaulted)
{
//Do Something
}
}
producerBuilder.Flush(FlushTimeout);


Подробнее здесь: https://stackoverflow.com/questions/792 ... nexception