Dong Lin commented on KAFKA-6705:

[~omkreddy] [~ijuma] Thanks for the reference to the previous discussion. It is 
very useful.

After reading through the email previous discussion, it seems that the previous 
discussion is not against the proposal here, i.e. producer.send() does not need 
to block on metadata update. I have created KIP 
 and opened thread for discussion. Can you provide comments? Thanks!

> producer.send() should not block due to metadata not available
> --------------------------------------------------------------
>                 Key: KAFKA-6705
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6705
>             Project: Kafka
>          Issue Type: Improvement
>            Reporter: Dong Lin
>            Assignee: Dong Lin
>            Priority: Major
> Currently producer.send() may block on metadata for up to max.block.ms. This 
> behavior is well documented but it is a bit sub-optimal. Since we return a 
> future we should be able to make producer.send() completely non-blocking. One 
> idea is to simply insert the record into a global queue shared across all 
> partitions, and let the sender thread fetch record from this queue and send 
> to broker.

This message was sent by Atlassian JIRA

Reply via email to