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

Место общения программистов C#
Ответить
Anonymous
 Ошибка производителя Kafka → System.InvalidOperationException

Сообщение 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
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «C#»