[jira] [Updated] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-649: Attachment: KAFKA-649.v3.patch > Cleanup log4j logging > - > >

[jira] [Updated] (KAFKA-649) Cleanup log4j logging

[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-649: Status: Patch Available (was: Reopened) Guidelines of cleaning: 1. Only errors causing the server

[jira] [Created] (KAFKA-991) Reduce the queue size in hadoop producer

Swapnil Ghike created KAFKA-991: --- Summary: Reduce the queue size in hadoop producer Key: KAFKA-991 URL: https://issues.apache.org/jira/browse/KAFKA-991 Project: Kafka Issue Type: Bug Affect

[jira] [Updated] (KAFKA-991) 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

[jira] [Created] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

Guozhang Wang created KAFKA-992: --- Summary: Double Check on Broker Registration to Avoid False NodeExist Exception Key: KAFKA-992 URL: https://issues.apache.org/jira/browse/KAFKA-992 Project: Kafka

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13724789#comment-13724789 ] Guozhang Wang commented on KAFKA-992: - We can differentiate this edge case from a tempo

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Status: Patch Available (was: Open) In ZkUtils.registerBrokerInZk: 1. Add the current timestamp in

[jira] [Updated] (KAFKA-991) 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: Attachment: kafka-991-v1.patch > Reduce the queue size in hadoop producer >

[jira] [Updated] (KAFKA-991) 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 > --