Description
Hello,
I was checking the value related to delivery.timeout.ms, and I found a relevant document here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-91+Provide+Intuitive+User+Timeouts+in+The+Producer
In the "Validation" section of the document, it is written as follows:
This configuration is backwards compatible. Throw ConfigException for timeouts that don't make sense. (E.g., delivery.timeout.ms < linger.ms + request.timeout.ms + retry.backoff.ms).
However, I noticed that the code does not use the retry.backoff.ms value when checking if delivery.timeout.ms is valid.
If it's not a bug, why was it excluded?
Attachments
Issue Links
- links to