File tree 1 file changed +5
-3
lines changed
1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -121,10 +121,12 @@ class KafkaProducer(object):
121
121
retries (int): Setting a value greater than zero will cause the client
122
122
to resend any record whose send fails with a potentially transient
123
123
error. Note that this retry is no different than if the client
124
- resent the record upon receiving the error. Allowing retries will
125
- potentially change the ordering of records because if two records
124
+ resent the record upon receiving the error. Allowing retries
125
+ without setting max_in_flight_connections_per_connection to 1 will
126
+ potentially change the ordering of records because if two batches
126
127
are sent to a single partition, and the first fails and is retried
127
- but the second succeeds, then the second record may appear first.
128
+ but the second succeeds, then the records in the second batch may
129
+ appear first.
128
130
Default: 0.
129
131
batch_size (int): Requests sent to brokers will contain multiple
130
132
batches, one for each partition with data available to be sent.
You can’t perform that action at this time.
0 commit comments