Когда клиент Apache Kafka генерирует исключение «Batch Expired»?

Используя Java-клиент Apache Kafka (0.9), я пытаюсь отправить длинный ряд записей брокеру, используяКафка Продюсер класс.

Асинхронныйотправить метод Немедленно возвращается на некоторое время, затем начинает блокировать каждый вызов на короткий промежуток времени. Примерно через тридцать секунд клиент начинает выдавать исключения (TimeoutException), с сообщением"Пакет истек".

Какие обстоятельства вызывают это исключение?

Ответы на вопрос(6)

Ваш ответ на вопрос