Исключение тайм-аута Kafka: срок действия партии истек - PullRequest
0 голосов
/ 01 октября 2018

Мы столкнулись со следующей проблемой при производстве:

org.apache.kafka.common.errors.TimeoutException: Batch Expired.

Это из-за неправильной конфигурации, такой как размер пакета, время ожидания запроса или что-то еще?

1 Ответ

0 голосов
/ 01 октября 2018

Ошибка указывает, что некоторые записи помещаются в очередь с большей скоростью, чем они могут быть отправлены с клиента.

Когда ваш источник отправляет сообщения, они сохраняются в буфере (перед отправкой целевому посреднику), и записи группируются в пакеты для увеличения пропускной способности.Когда новая запись добавляется в пакет, она должна быть отправлена ​​в пределах окна -configurable- time, которое управляется request.timeout.ms (по умолчанию установлено значение 30 секунд).Если пакет находится в очереди в течение более длительного времени, выдается TimeoutException, и записи пакета затем удаляются из очереди и не будут доставлены посреднику.

Увеличение значения request.timeout.ms должно помочь вам.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...