Details
-
Sub-task
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
0.11.0.0
Description
Due to a race condition between the sender thread and the producer.send(), the following is possible:
- In KakfaProducer.doSend(), we add partitions to the transaction and then do accumulator.append.
- In Sender.run(), we check whether there are transactional request. If there are, we send them and wait for the response.
- If there aren't we drain the accumulator queue and send the produce requests.
- The problem is that the sequence step 2, 1, 3 is entire possible. This means that we won't send the 'AddPartitions' request but yet try to send the produce data. Which results in a fatal error and requires the producer to close.
The solution is that in the accumulator.drain, we should check again if there are pending add partitions requests, and if so, don't drain anything.