[
https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16470127#comment-16470127
]
Anurag Jain commented on KAFKA-2200:
------------------------------------
HI [~becket_qin],
Please correct me if I am wrong.
if a producer send request to broker and producer got timeout exception from
broker because of failure to receive required number of Acks. Then producer
retry again to send this batch to broker, as TimeoutException falls under
RetriableException category. In this case, at producer side it didn't call
onComplete method of batch.
onComplete method is called only in case, batch is expired.
> kafkaProducer.send() should not call callback.onCompletion()
> ------------------------------------------------------------
>
> Key: KAFKA-2200
> URL: https://issues.apache.org/jira/browse/KAFKA-2200
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 0.10.1.0
> Reporter: Jiangjie Qin
> Priority: Major
> Labels: newbie
> Fix For: 2.0.0
>
>
> KafkaProducer.send() should not call callback.onCompletion() because this
> might break the callback firing order.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
