Quando o cliente Apache Kafka lança uma exceção "Expiração em lote"?
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?