[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059188#comment-14059188 ] nicu marasoiu commented on KAFKA-1535: -- Hi, I am a 11 years java developer and

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059203#comment-14059203 ] nicu marasoiu commented on KAFKA-1535: -- So what I understand from the issue: the

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059209#comment-14059209 ] nicu marasoiu commented on KAFKA-1476: -- if you just browse zookeeper with some

[jira] [Commented] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059216#comment-14059216 ] nicu marasoiu commented on KAFKA-1326: -- Hey guys, What can I take from the

[jira] [Commented] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059221#comment-14059221 ] nicu marasoiu commented on KAFKA-1330: -- Hi, If I want to take this, how much time to

[jira] [Comment Edited] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059216#comment-14059216 ] nicu marasoiu edited comment on KAFKA-1326 at 7/11/14 7:21 PM:

[jira] [Comment Edited] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059216#comment-14059216 ] nicu marasoiu edited comment on KAFKA-1326 at 7/11/14 7:24 PM:

[jira] [Commented] (KAFKA-167) Move partition assignment to the broker

[ https://issues.apache.org/jira/browse/KAFKA-167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059796#comment-14059796 ] nicu marasoiu commented on KAFKA-167: - Hi, So I would suggest this: for each consumer

[jira] [Commented] (KAFKA-264) Change the consumer side load balancing and distributed co-ordination to use a consumer co-ordinator

[ https://issues.apache.org/jira/browse/KAFKA-264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14059798#comment-14059798 ] nicu marasoiu commented on KAFKA-264: -

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Status: Patch Available (was: Open) I attached a patch generated with Idea. Please let me know

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Attachment: KAFKA-1535__return_all_live_brokers_in_TopicMetadataResponse1.patch return all

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14064211#comment-14064211 ] nicu marasoiu commented on KAFKA-1535: -- Hi Jay, Great:) For the tests, I just run

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Attachment: (was: KAFKA-1535__return_all_live_brokers_in_TopicMetadataResponse1.patch)

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Attachment: KAFKA-1535__return_all_live_brokers_in_TopicMetadataResponse.patch return all live

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Attachment: (was: KAFKA-1535__return_all_live_brokers_in_TopicMetadataResponse.patch)

[jira] [Updated] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1535: - Attachment: KAFKA-1535__return_all_live_brokers_in_TopicMetadataResponse_.patch return all

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065424#comment-14065424 ] nicu marasoiu commented on KAFKA-1535: -- updated patch, tests fine, one question

[jira] [Comment Edited] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14065424#comment-14065424 ] nicu marasoiu edited comment on KAFKA-1535 at 7/17/14 7:32 PM:

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066538#comment-14066538 ] nicu marasoiu commented on KAFKA-1535: -- Sure do want:) Yes, that was my suggestion as

[jira] [Assigned] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu reassigned KAFKA-1282: Assignee: nicu marasoiu Disconnect idle socket connection in Selector

[jira] [Commented] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066548#comment-14066548 ] nicu marasoiu commented on KAFKA-1549: -- test if i receive mails on this jira task

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Description: JunRao confirming my observation that brokers are only added to the metadataCache,

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Affects Version/s: 0.8.2 dead brokers coming in the TopicMetadataResponse

[jira] [Assigned] (KAFKA-1510) Force offset commits at a minimum interval when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu reassigned KAFKA-1510: Assignee: nicu marasoiu Force offset commits at a minimum interval when migrating

[jira] [Commented] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066784#comment-14066784 ] nicu marasoiu commented on KAFKA-1549: -- esepntially i will replace the list/map of

[jira] [Commented] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066791#comment-14066791 ] nicu marasoiu commented on KAFKA-1535: -- created KAFKA-1549 with Major priority. I

[jira] [Comment Edited] (KAFKA-1535) return all live brokers in TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14066791#comment-14066791 ] nicu marasoiu edited comment on KAFKA-1535 at 7/18/14 7:50 PM:

[jira] [Work started] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-1549 started by nicu marasoiu. dead brokers coming in the TopicMetadataResponse Key:

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Assignee: Jun Rao (was: nicu marasoiu) Status: Patch Available (was: In Progress) i

[jira] [Comment Edited] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068442#comment-14068442 ] nicu marasoiu edited comment on KAFKA-1549 at 7/21/14 12:07 PM:

[jira] [Commented] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068442#comment-14068442 ] nicu marasoiu commented on KAFKA-1549: -- 2. Indeed, to avoid that overhead and make it

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment: (was: KAFKA-1549__dead_brokers_coming_in_the_TopicMetadataResponse_.patch)

[jira] [Comment Edited] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068442#comment-14068442 ] nicu marasoiu edited comment on KAFKA-1549 at 7/21/14 12:09 PM:

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment:

[jira] [Issue Comment Deleted] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Comment: was deleted (was: Implemented point 1 and reverted for point 2, attached patch) dead

[jira] [Comment Edited] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068442#comment-14068442 ] nicu marasoiu edited comment on KAFKA-1549 at 7/21/14 5:53 PM:

[jira] [Comment Edited] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068442#comment-14068442 ] nicu marasoiu edited comment on KAFKA-1549 at 7/21/14 6:05 PM:

[jira] [Comment Edited] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068442#comment-14068442 ] nicu marasoiu edited comment on KAFKA-1549 at 7/21/14 6:06 PM:

[jira] [Commented] (KAFKA-1553) TopicMetadataResponse.brokers not read in scala producer?

[ https://issues.apache.org/jira/browse/KAFKA-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068944#comment-14068944 ] nicu marasoiu commented on KAFKA-1553: -- Hi, what does the new producer mean, is a

[jira] [Comment Edited] (KAFKA-1553) TopicMetadataResponse.brokers not read in scala producer?

[ https://issues.apache.org/jira/browse/KAFKA-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14068944#comment-14068944 ] nicu marasoiu edited comment on KAFKA-1553 at 7/21/14 6:18 PM:

[jira] [Resolved] (KAFKA-1553) TopicMetadataResponse.brokers not read in scala producer?

[ https://issues.apache.org/jira/browse/KAFKA-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu resolved KAFKA-1553. -- Resolution: Duplicate TopicMetadataResponse.brokers not read in scala producer?

[jira] [Commented] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14069189#comment-14069189 ] nicu marasoiu commented on KAFKA-1549: -- added an implementation without the implicit:

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment:

[jira] [Commented] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14070751#comment-14070751 ] nicu marasoiu commented on KAFKA-1549: -- [~jkreps] [~junrao] Hi, can you help me

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment:

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment: (was:

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075447#comment-14075447 ] nicu marasoiu commented on KAFKA-1510: -- Hi, I am confused. Let me state some

[jira] [Comment Edited] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075447#comment-14075447 ] nicu marasoiu edited comment on KAFKA-1510 at 7/26/14 6:40 PM:

[jira] [Comment Edited] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075447#comment-14075447 ] nicu marasoiu edited comment on KAFKA-1510 at 7/26/14 6:48 PM:

[jira] [Updated] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Attachment: forceCommitOnShutdownWhenDualCommit.patch attached the patch with the meaning

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075473#comment-14075473 ] nicu marasoiu commented on KAFKA-1510: -- forcing all to zk too does indeed have the

[jira] [Comment Edited] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075473#comment-14075473 ] nicu marasoiu edited comment on KAFKA-1510 at 7/26/14 7:39 PM:

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment: (was:

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment: (was:

[jira] [Updated] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1549: - Attachment: bringAllBrokers.patch attached dead brokers coming in the TopicMetadataResponse

[jira] [Comment Edited] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075475#comment-14075475 ] nicu marasoiu edited comment on KAFKA-1549 at 7/26/14 7:46 PM:

[jira] [Comment Edited] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075473#comment-14075473 ] nicu marasoiu edited comment on KAFKA-1510 at 7/27/14 6:34 AM:

[jira] [Issue Comment Deleted] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Comment: was deleted (was: attached the patch with the meaning detailed in my prev comment)

[jira] [Comment Edited] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14075447#comment-14075447 ] nicu marasoiu edited comment on KAFKA-1510 at 7/27/14 6:38 AM:

[jira] [Issue Comment Deleted] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Comment: was deleted (was: forcing all to zk too does indeed have the drawback that it will

[jira] [Assigned] (KAFKA-1549) dead brokers coming in the TopicMetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu reassigned KAFKA-1549: Assignee: Jun Rao (was: nicu marasoiu) dead brokers coming in the TopicMetadataResponse

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14078904#comment-14078904 ] nicu marasoiu commented on KAFKA-1510: -- [~jjkoshy] Can you please take a look at my

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079219#comment-14079219 ] nicu marasoiu commented on KAFKA-1510: -- [~jkreps] Hi, can you please help me with

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14082166#comment-14082166 ] nicu marasoiu commented on KAFKA-1510: -- Hi, the || forceCommit on line 318 is meant

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14083551#comment-14083551 ] nicu marasoiu commented on KAFKA-1510: -- Hi, I have given it more consideration, and

[jira] [Updated] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Attachment: (was: forceCommitOnShutdownWhenDualCommit.patch) Force offset commits when

[jira] [Updated] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Attachment: kafka-1510.patch Force offset commits when migrating consumer offsets from

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14083878#comment-14083878 ] nicu marasoiu commented on KAFKA-1510: -- re-uploaded the patch Force offset commits

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14090832#comment-14090832 ] nicu marasoiu commented on KAFKA-1282: -- Hi, I will spend 1-2 hours per day the next

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14090832#comment-14090832 ] nicu marasoiu edited comment on KAFKA-1282 at 8/8/14 3:37 PM: --

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: kafka-1282__Disconnect_idle_socket_connection_in_Selector.patch Disconnect idle

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Status: Patch Available (was: In Progress) Disconnect idle socket connection in Selector

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14094686#comment-14094686 ] nicu marasoiu commented on KAFKA-1282: -- I attached a first version of the patch. I am

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14097047#comment-14097047 ] nicu marasoiu commented on KAFKA-1282: -- Traversing is quite cheap and can be done

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14097047#comment-14097047 ] nicu marasoiu edited comment on KAFKA-1282 at 8/14/14 3:06 PM:

[jira] [Assigned] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu reassigned KAFKA-1461: Assignee: nicu marasoiu (was: Neha Narkhede) Replica fetcher thread does not implement

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14097380#comment-14097380 ] nicu marasoiu commented on KAFKA-1282: -- To make the ~O(1) cost of traversing more

[jira] [Assigned] (KAFKA-1546) Automate replica lag tuning

[ https://issues.apache.org/jira/browse/KAFKA-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu reassigned KAFKA-1546: Assignee: nicu marasoiu Automate replica lag tuning ---

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14110261#comment-14110261 ] nicu marasoiu commented on KAFKA-1282: -- Hi, Thank you, for 2. I agree for producers

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282_final.patch uploaded with parametrization and no more access-touch from write

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282.patch Disconnect idle socket connection in Selector

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: 1282_final.patch) Disconnect idle socket connection in Selector

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: kafka-1282__Disconnect_idle_socket_connection_in_Selector.patch)

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14114244#comment-14114244 ] nicu marasoiu commented on KAFKA-1510: -- Hi, I will do this tomorrow, Friday, so I

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14114248#comment-14114248 ] nicu marasoiu commented on KAFKA-1282: -- [~nehanarkhede] Hi, I implemented our

[jira] [Issue Comment Deleted] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Comment: was deleted (was: The patch makes the simplest choices: 1. unfiltered commits when

[jira] [Updated] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Attachment: (was: kafka-1510.patch) Force offset commits when migrating consumer offsets

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: 1282.patch) Disconnect idle socket connection in Selector

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14117638#comment-14117638 ] nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:18 PM: --

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14117638#comment-14117638 ] nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:25 PM: --

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14117638#comment-14117638 ] nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:28 PM: --

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14118294#comment-14118294 ] nicu marasoiu commented on KAFKA-1510: -- [~jjkoshy] Hi, can you check my patch +

[jira] [Updated] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Attachment: (was: Unfiltered_to_kafka,_Incremental_to_Zookeeper.patch) Force offset commits

[jira] [Updated] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1510: - Attachment: Unfiltered_offsets_commit_to_kafka_rebased.patch Attached rebased patch Force

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14122456#comment-14122456 ] nicu marasoiu commented on KAFKA-1282: -- Hi, I am not completely sure I fully

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14125465#comment-14125465 ] nicu marasoiu commented on KAFKA-1282: -- [~junrao], hi, can you answer please? I agree

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282_the_ultimate,_close_max_one_per_select.patch Attached patch: every select

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14137011#comment-14137011 ] nicu marasoiu commented on KAFKA-1282: -- Hi, Unfortunately the client used in

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14137011#comment-14137011 ] nicu marasoiu edited comment on KAFKA-1282 at 9/17/14 9:53 AM:

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282_brushed_up.patch re-attached fixed patch, but we may have a blocker to the whole

  1   2   >