¿Cuándo lanza el cliente Apache Kafka una excepción de "Batch Expired"?

Usando el cliente Java Apache Kafka (0.9), estoy tratando de enviar una larga serie de registros al corredor usando elClase de productor Kafka.

El asincrónicométodo de envío regresa inmediatamente por un tiempo, luego comienza a bloquear cada llamada por un corto período de tiempo. Después de unos treinta segundos, el cliente comienza a lanzar excepciones (TimeoutException), con el mensaje"Lote caducado".

¿Qué circunstancias hacen que se produzca esta excepción?

Respuestas a la pregunta(6)

Su respuesta a la pregunta