[jira] [Updated] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-253: -- Attachment: kafka-253_v5.patch Attach patch v5. Minor changes in DefaultEventHandler to correctly handle retrie

[jira] [Updated] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-253: -- Attachment: kafka-253_v4.patch Attach patch v4. Made the following changes: 1. Renamed AsyncProducerConfigShared

[jira] [Updated] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-253: -- Attachment: kafka-253_v3.patch Attached v3 patch by rebasing to trunk. > Refactor the async pro

[jira] [Updated] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-253: -- Attachment: kafka-253_v2.patch Uploaded patch v2. 1. removed 2. made it case class 3.1 changed. 3.2 removed #eve

[jira] [Updated] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-253: -- Status: Patch Available (was: Open) The patch can go into 0.7 too. > Refactor the async produc

[jira] [Updated] (KAFKA-253) Refactor the async producer to have only one queue instead of one queue per broker in a Kafka cluster

[ https://issues.apache.org/jira/browse/KAFKA-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-253: -- Attachment: kafka-253.patch Attach a patch. The current Producer logic has a number of problems: 1. There are 2