[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-991:
-
Resolution: Fixed
Status: Resolved (was: Patch Available)
> Reduce the queue size in hadoop p
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-followup-3.patch
Thanks, attached a new patch to address that.
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-followup-v2.patch
Fixed README.
> Reduce the queue size in ha
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-followup.patch
> Reduce the queue size in hadoop producer
> --
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Description:
Currently the queue.size in hadoop producer is 10MB. This means that the
KafkaRecordWr
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Attachment: kafka-991-v1.patch
> Reduce the queue size in hadoop producer
>
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Status: Patch Available (was: Open)
> Reduce the queue size in hadoop producer
> --
[
https://issues.apache.org/jira/browse/KAFKA-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-991:
Description:
Currently the queue.size in hadoop producer is 10MB. This means that the
KafkaRecordWr