Hi All,

We're using the "org.apache.kafka.kafka-clients" library version "0.9.0.1".
We're running 0.9.0.1 brokers.

I've been tracking down "org.apache.kafka.common.errors.TimeoutException:
Batch Expired" issues in our producer.

Based on my local testing, it looks like it doesn't actually retry messages
when we lose the leader. Based on the docs it looks like it should be
retrying these failures.

I read through a number of issues relating to this, like KAFKA-3594
<https://issues.apache.org/jira/browse/KAFKA-3594> and KAFKA-4515
<https://issues.apache.org/jira/browse/KAFKA-4515>.

Should we:

   - Fork the client and patch fixes for these issues?
   - Set "retries" to 0 and implement the retries at the application level?
   - Wait on a 0.9.0.2 release of the kafka client?
   - Some unknown other thing?


If you've run into this issue, or have worked on the client, I'd love to
hear from you!

Thanks a ton,
Andrew Clarkson

Reply via email to