Usando o cliente Apache Kafka Java (0.9), estou tentando enviar uma longa série de registros para o broker usando oKafka Producer class.

O assíncronométodo de envio retorna imediatamente por um tempo e começa a bloquear cada chamada por um curto período de tempo. Após cerca de trinta segundos, o cliente começa a lançar exceções (TimeoutException), com a mensagem"Lote expirado".

Que circunstâncias fazem com que essa exceção seja lançada?