[jira] [Commented] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13731608#comment-13731608 ] Neha Narkhede commented on KAFKA-999: - +1 on v3. > Controlled shutdow

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-999: Resolution: Fixed Status: Resolved (was: Patch Available) Committed v3 to 0.8

[jira] [Updated] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

[ https://issues.apache.org/jira/browse/KAFKA-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-1003: - Attachment: kafka-1003.patch > ConsumerFetcherManager should pass clientId as metricsPrefix t

[jira] [Created] (KAFKA-1003) ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager

Swapnil Ghike created KAFKA-1003: Summary: ConsumerFetcherManager should pass clientId as metricsPrefix to AbstractFetcherManager Key: KAFKA-1003 URL: https://issues.apache.org/jira/browse/KAFKA-1003

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Attachment: (was: LIKAFKA-269-v3.patch) > Controlled shutdown never succeeds until the broke

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Attachment: kafka-999-v3.patch > Controlled shutdown never succeeds until the broker is killed >

[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: Attachment: KAFKA-992.v5.patch > Double Check on Broker Registration to Avoid False NodeExist Ex

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Attachment: LIKAFKA-269-v3.patch Renamed to leaders at one another place. > Control

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Attachment: kafka-999-v2.patch Thanks for pointing that out. Actually in ControllerChannelManager, w

[jira] [Commented] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13731427#comment-13731427 ] Neha Narkhede commented on KAFKA-999: - Thanks for the patch Swapnil. Overall, well thou

[jira] [Comment Edited] (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=13731353#comment-13731353 ] Guozhang Wang edited comment on KAFKA-992 at 8/6/13 10:26 PM: --

[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=13731353#comment-13731353 ] Guozhang Wang commented on KAFKA-992: - The zookeeper bug can be reproduced as follows:

[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=13731352#comment-13731352 ] Neha Narkhede commented on KAFKA-992: - We just found a way to reliably reproduce the zo

[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=13731337#comment-13731337 ] Joel Koshy commented on KAFKA-992: -- and nm for my comments about controller/consumers as w

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Attachment: kafka-999-v1.patch > Controlled shutdown never succeeds until the broker is killed >

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Attachment: (was: kafka-991-v1.patch) > Controlled shutdown never succeeds until the broker

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Attachment: kafka-991-v1.patch Small-scale fix for 0.8. > Controlled shutdown neve

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Status: Patch Available (was: Open) > Controlled shutdown never succeeds until the broker is ki

[jira] [Updated] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Assignee: Swapnil Ghike (was: Neha Narkhede) > Controlled shutdown never succeeds until the bro

[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=13731282#comment-13731282 ] Joel Koshy commented on KAFKA-992: -- ok nm the comment about timestamp. I had forgotten tha

[jira] [Updated] (KAFKA-990) Fix ReassignPartitionCommand and improve usability

[ https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-990: - Attachment: KAFKA-990-v1.patch > Fix ReassignPartitionCommand and improve usability >

[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=13731187#comment-13731187 ] Joel Koshy commented on KAFKA-992: -- Delayed review - looks good to me, although I still do

[jira] [Commented] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13731174#comment-13731174 ] Swapnil Ghike commented on KAFKA-999: - Actually that's not needed, will get a patch out

[jira] [Issue Comment Deleted] (KAFKA-999) Controlled shutdown never succeeds until the broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-999: Comment: was deleted (was: Actually that's not needed, will get a patch out in a couple hours.)

Re: Fixes for 0.8 in trunk, absent from 0.8 branch

Yes, what is perhaps confusing is that 0.8 is essentially the "release branch" only fixes required for 0.8 final are going there. All other development is on trunk which will be kafka.next, which we are calling 0.8.1. Hope that helps. -Jay On Tue, Aug 6, 2013 at 9:25 AM, Jun Rao wrote: > Actua

[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=13730916#comment-13730916 ] Jun Rao commented on KAFKA-992: --- Thinking about this more. The same ZK issue can affect the c

Re: Fixes for 0.8 in trunk, absent from 0.8 branch

Actually, all of them are marked as fixed in 0.8.1. Thanks, Jun On Tue, Aug 6, 2013 at 3:43 AM, Cosmin Lehene wrote: > Hey guys, > > There are a few fixes which are marked for 0.8 and "fixed" in JIRA but > have only been pushed to trunk and missing from 0.8 > > https://issues.apache.org/jira/

[jira] [Commented] (KAFKA-989) Race condition shutting down high-level consumer results in spinning background thread

[ https://issues.apache.org/jira/browse/KAFKA-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730787#comment-13730787 ] Phil Hargett commented on KAFKA-989: Thank you! > Race condition shutt

[jira] [Commented] (KAFKA-347) change number of partitions of a topic online

[ https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13730616#comment-13730616 ] Cosmin Lehene commented on KAFKA-347: - Is there some operational documentation on how t

Fixes for 0.8 in trunk, absent from 0.8 branch

Hey guys, There are a few fixes which are marked for 0.8 and "fixed" in JIRA but have only been pushed to trunk and missing from 0.8 https://issues.apache.org/jira/browse/KAFKA-925 https://issues.apache.org/jira/browse/KAFKA-852 https://issues.apache.org/jira/browse/KAFKA-995 https://issues.apac