Wann löst der Apache Kafka-Client eine "Batch Expired" -Ausnahme aus?

Mit dem Apache Kafka Java-Client (0.9) versuche ich, eine lange Reihe von Datensätzen mit dem @ -Zeichen an den Broker zu sendeKafka Produzentenklasse.

Die asynchronesend method kehrt sofort für eine Weile zurück und beginnt dann, jeden Anruf für einen kurzen Zeitraum zu blockieren. Nach ungefähr 30 Sekunden beginnt der Client mit dem Auslösen von Ausnahmen TimeoutException), mit der Meldung "Stapel abgelaufen".

Welche Umstände lösen diese Ausnahme aus?

Antworten auf die Frage(12)

Ihre Antwort auf die Frage