[KAFKA-3190] KafkaProducer should not invoke callback in send()

• Type: Bug
• Status: Patch Available
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 0.9.0.0
• Component/s: clients, producer
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Reviewer: Guozhang Wang
• Created: 02/Feb/16 03:19
• Updated: 09/Feb/22 19:33

Description

Currently KafkaProducer will invoke callback.onComplete() if it receives an ApiException during send(). This breaks the guarantee that callback will be invoked in order. It seems ApiException in send() only comes from metadata refresh. If so, we can probably simply throw it instead of invoking callback().

Issue Links

• relates to: KAFKA-2200 kafkaProducer.send() should not call callback.onCompletion()
• links to: GitHub Pull Request #880