[jira] [Resolved] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-776. - Resolution: Fixed Checked in v2 > Changing ZK format breaks some tools >

[jira] [Commented] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13589133#comment-13589133 ] Neha Narkhede commented on KAFKA-776: - +1 on patch v2 > Changing ZK fo

[jira] [Closed] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-776. --- > Changing ZK format breaks some tools > > > Key:

[jira] [Updated] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-776: Attachment: kafka-776-v2.patch Attached the changes. > Changing ZK format breaks so

[jira] [Commented] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13589091#comment-13589091 ] Neha Narkhede commented on KAFKA-776: - Thanks for the patch. Overall looks good, few re

[jira] [Updated] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-776: Attachment: kafka-776-v1.patch Attached a patch to fix the 4 tools. > Changing ZK f

[jira] [Assigned] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-330: --- Assignee: Swapnil Ghike (was: Neha Narkhede) > Add delete topic support > --

[jira] [Commented] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13588933#comment-13588933 ] Neha Narkhede commented on KAFKA-330: - Here is a broad description of how delete topic

[jira] [Commented] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13588922#comment-13588922 ] Swapnil Ghike commented on KAFKA-776: - >From what I see in the code, kafka.admin.Shutdo

[jira] [Work started] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-776 started by Swapnil Ghike. > Changing ZK format breaks some tools > > > Key: KAFKA-776 >

[jira] [Updated] (KAFKA-776) Changing ZK format breaks some tools

[ https://issues.apache.org/jira/browse/KAFKA-776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-776: Labels: kafka-0.8 p1 (was: p1) > Changing ZK format breaks some tools > ---

[jira] [Created] (KAFKA-776) Changing ZK format breaks some tools

Sriram Subramanian created KAFKA-776: Summary: Changing ZK format breaks some tools Key: KAFKA-776 URL: https://issues.apache.org/jira/browse/KAFKA-776 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13588677#comment-13588677 ] Swapnil Ghike commented on KAFKA-513: - Um just curious, did you look at my comments whi

[jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13588664#comment-13588664 ] Neha Narkhede commented on KAFKA-513: - Thanks for patch v3. Overall, its pretty good, a

Re: Please clean your ZK and Kafka data if you check out 0.8 HEAD

Did you upgrade your console consumer? Thanks, Jun On Wed, Feb 27, 2013 at 3:40 AM, ben fleis wrote: > Sorry, I should have clarified something -- using the normal > ConsoleConsumer does *not* produce this error. So something in my > formatter, or in the logic of a custom formatter must chang

Re: Get all the partion details from zookeeper for a topic

Sourabh, In 0.7, you can use zkclient or the zookeeper client library to query the following zookeeper path to get a number of partitions for a topic - get /brokers/topics/[topic]/[broker-id] This will give you # of partitions/broker, you can then add up this value across all brokers. Thanks, N

Re: Get all the partion details from zookeeper for a topic

Hi All, I am using zookeeper based connector to get data from Kafka Server. Is there any way to get all the partitions from zookeeper for a given topic? I need do do that through java code. Please help!!! Thanks.

Re: Please clean your ZK and Kafka data if you check out 0.8 HEAD

Sorry, I should have clarified something -- using the normal ConsoleConsumer does *not* produce this error. So something in my formatter, or in the logic of a custom formatter must change? ben

Re: Please clean your ZK and Kafka data if you check out 0.8 HEAD

Hi Swapnil, I have done exactly this (killed and wiped everything), and have found that my custom formatter based ConsoleConsumer fails: [2013-02-27 12:34:31,420] ERROR Error processing message, stopping consumer: (kafka.consumer.ConsoleConsumer$) java.lang.NumberFormatException: For input strin