All Lead Replica are on a Single Broker

Kafka Dev, I am not sure if we are missing something over here but after cluster restart I see all the existing topics choose one broker as the Lead replica which is probably not a right behavior as we want to distribute the load across the cluster opic: credit.cache.smc.debt.queue parti

Re: All Lead Replica are on a Single Broker

I think Joel answered a similar question in the user mailing list. You can run the preferred replica leader election tool after the restarts ( https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools) Thanks, Jun On Wed, Aug 14, 2013 at 6:22 AM, Kumar, Vaibhav wrote: > Kafka Dev, >

Debug w/ IntelliJ

I'm trying to use IntelliJ to debug Kafka, and although my breakpoint is triggered I don't get any local variables debug info available. I generated the intellij files using sbt gen-idea. I wonder how do others able to get debug info in IntelliJ? Thanks, Tim

[jira] [Created] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

Jun Rao created KAFKA-1009: -- Summary: DumpLogSegments tool should return error on non-existing files Key: KAFKA-1009 URL: https://issues.apache.org/jira/browse/KAFKA-1009 Project: Kafka Issue Type:

[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=13739857#comment-13739857 ] Jun Rao commented on KAFKA-992: --- v10 doesn't seem to apply to current 0.8.

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

[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elizabeth Wei updated KAFKA-1008: - Attachment: unmap-v3.patch > Unmap before resizing > - > >

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

[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elizabeth Wei updated KAFKA-1008: - Attachment: (was: unmap-v2.patch) > Unmap before resizing > - > >

[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=13739926#comment-13739926 ] Elizabeth Wei commented on KAFKA-1008: -- Thanks, I added the try/catch to handle the e

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

[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elizabeth Wei updated KAFKA-1008: - Attachment: unmap-v4.patch > Unmap before resizing > - > >

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

[ https://issues.apache.org/jira/browse/KAFKA-1008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elizabeth Wei updated KAFKA-1008: - Attachment: (was: unmap-v3.patch) > Unmap before resizing > - > >

[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.v11.patch Forgot to pull before rebase, the new version apply to latest 0.8 no

[jira] [Updated] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1009: - Assignee: Guozhang Wang > DumpLogSegments tool should return error on non-existing files > --

[jira] [Commented] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13740470#comment-13740470 ] Guozhang Wang commented on KAFKA-1009: -- This is due to the fact that in dumpLog, it c

[jira] [Updated] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1009: - Attachment: KAFKA-1009.v1.patch > DumpLogSegments tool should return error on non-existing fi

[jira] [Updated] (KAFKA-1009) DumpLogSegments tool should return error on non-existing files

[ https://issues.apache.org/jira/browse/KAFKA-1009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1009: - Status: Patch Available (was: Open) > DumpLogSegments tool should return error on non-existi

[jira] [Updated] (KAFKA-1007) Document new tools before 0.8 release

[ https://issues.apache.org/jira/browse/KAFKA-1007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1007: - Assignee: Guozhang Wang > Document new tools before 0.8 release > ---

[jira] [Updated] (KAFKA-1004) Handle topic event for trivial whitelist topic filters

[ https://issues.apache.org/jira/browse/KAFKA-1004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1004: - Attachment: KAFKA-1004.v1.patch > Handle topic event for trivial whitelist topic filters > --

[jira] [Updated] (KAFKA-1004) Handle topic event for trivial whitelist topic filters

[ https://issues.apache.org/jira/browse/KAFKA-1004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1004: - Status: Patch Available (was: Open) > Handle topic event for trivial whitelist topic filters

[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=13740611#comment-13740611 ] Jay Kreps commented on KAFKA-1008: -- But my understanding is that these copies are just co

[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=13740742#comment-13740742 ] Elizabeth Wei commented on KAFKA-1008: -- That's right, the duplicate is a shallow copy