Jiangjie Qin created KAFKA-3190: ----------------------------------- Summary: KafkaProducer should not invoke callback in send() Key: KAFKA-3190 URL: https://issues.apache.org/jira/browse/KAFKA-3190 Project: Kafka Issue Type: Bug Components: clients, producer Affects Versions: 0.9.0.0 Reporter: Jiangjie Qin Assignee: Jiangjie Qin Fix For: 0.9.0.1
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(). -- This message was sent by Atlassian JIRA (v6.3.4#6332)