Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
2.4.0
-
None
Description
As of 2.4, the KafkaProducer documentation states:
If the request fails, the producer can automatically retry, though since we have specified retries as 0 it won't.
... in the code snippet above, likely all 100 records would be sent in a single request since we set our linger time to 1 millisecond.
However, the code snippet (below) does not include any configurtaion on 'retry' or 'linger.ms':
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
The same documentation in version 2.0 includes the configs; However, 2.1 only includes 'linger.ms' and 2.2 includes none. It seems like it was removed in the middle of two releases.
Attachments
Issue Links
- links to