[jira] [Updated] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1011: - Assignee: Guozhang Wang > Decompression and re-compression on MirrorMaker could result in mes

[jira] [Commented] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13747631#comment-13747631 ] Guozhang Wang commented on KAFKA-1011: -- Proposed Approach: 1. Since the compression

[jira] [Created] (KAFKA-1019) kafka-preferred-replica-election.sh will fail without clear error message if /brokers/topics/[topic]/partitions does not exist

Guozhang Wang created KAFKA-1019: Summary: kafka-preferred-replica-election.sh will fail without clear error message if /brokers/topics/[topic]/partitions does not exist Key: KAFKA-1019 URL: https://issues.apache.

[jira] [Resolved] (KAFKA-1017) High number of open file handles in 0.8 producer

[ https://issues.apache.org/jira/browse/KAFKA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1017. Resolution: Fixed Fix Version/s: 0.8 Good patch. +1. Committed to 0.8. > High numbe

[jira] [Commented] (KAFKA-1017) High number of open file handles in 0.8 producer

[ https://issues.apache.org/jira/browse/KAFKA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13747663#comment-13747663 ] Guozhang Wang commented on KAFKA-1017: -- Good catch, thanks Swapnil!

[jira] [Commented] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13747692#comment-13747692 ] Jun Rao commented on KAFKA-955: --- Magnus, thanks for your comment. What you suggested is inter

[jira] [Updated] (KAFKA-955) After a leader change, messages sent with ack=0 are lost

[ https://issues.apache.org/jira/browse/KAFKA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-955: Attachment: KAFKA-955.v4.patch Thanks for the comments Jun. 30. Done. 31. After a second thought I

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (69 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1012 Implement an Offset Manager and hook offset requests to it https://issues.apache.org/jira/browse/KAFKA-1012 KAFK

[jira] [Created] (KAFKA-1020) Remove getAllReplicasOnBroker from KafkaController

Guozhang Wang created KAFKA-1020: Summary: Remove getAllReplicasOnBroker from KafkaController Key: KAFKA-1020 URL: https://issues.apache.org/jira/browse/KAFKA-1020 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-949) Integrate kafka into YARN

[ https://issues.apache.org/jira/browse/KAFKA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13748147#comment-13748147 ] Kam Kasravi commented on KAFKA-949: --- This work is available under https://github.com/kkas

[jira] [Commented] (KAFKA-1008) Unmap before resizing

[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13748206#comment-13748206 ] David Lao commented on KAFKA-1008: -- Hi Jay, The patch does not seem to apply cleanly on t

[jira] [Comment Edited] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13747631#comment-13747631 ] Guozhang Wang edited comment on KAFKA-1011 at 8/23/13 2:30 AM: -

[jira] [Comment Edited] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13747631#comment-13747631 ] Guozhang Wang edited comment on KAFKA-1011 at 8/23/13 2:32 AM: -

[jira] [Comment Edited] (KAFKA-1011) Decompression and re-compression on MirrorMaker could result in messages being dropped in the pipeline

[ https://issues.apache.org/jira/browse/KAFKA-1011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13747631#comment-13747631 ] Guozhang Wang edited comment on KAFKA-1011 at 8/23/13 3:13 AM: -