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

2013-03-05 Thread sourabh chaki
Hi Neha, I am using zkclient version 0.1. I dont see any method "getData" in zkclient. Please let me know which version should I use. Thanks Sourabh On Tue, Mar 5, 2013 at 10:01 PM, Neha Narkhede wrote: > The problem is that you need to invoke getData, not getChildren on this > path - /brokers/

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

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13594379#comment-13594379 ] Neha Narkhede commented on KAFKA-513: - I think there is some issue with patch v5. I get

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

2013-03-05 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-513: Attachment: kafka-513-v5.patch Thank you for the detailed suggestions, they were incredibly helpful.

[jira] [Updated] (KAFKA-791) Fix validation bugs in System Test

2013-03-05 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-791: Description: The following issues are found in data / log checksum match in System Test: 1. kafka_system_te

[jira] [Resolved] (KAFKA-104) Invalid topics prevent broker start-up

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-104. - Resolution: Cannot Reproduce > Invalid topics prevent broker start-up > --

[jira] [Closed] (KAFKA-104) Invalid topics prevent broker start-up

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-104. --- > Invalid topics prevent broker start-up > -- > >

[jira] [Updated] (KAFKA-792) Update multiple attributes in testcase_xxxx_properties.json

2013-03-05 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-792: Description: The following are some of the properties need to be updated in some testcase__properties.j

[jira] [Updated] (KAFKA-791) Fix validation bugs in System Test

2013-03-05 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-791: Issue Type: Task (was: Bug) > Fix validation bugs in System Test > -- >

[jira] [Created] (KAFKA-792) Update multiple attributes in testcase_xxxx_properties.json

2013-03-05 Thread John Fung (JIRA)
John Fung created KAFKA-792: --- Summary: Update multiple attributes in testcase__properties.json Key: KAFKA-792 URL: https://issues.apache.org/jira/browse/KAFKA-792 Project: Kafka Issue Type: Ta

[jira] [Created] (KAFKA-791) Fix validation bugs in System Test

2013-03-05 Thread John Fung (JIRA)
John Fung created KAFKA-791: --- Summary: Fix validation bugs in System Test Key: KAFKA-791 URL: https://issues.apache.org/jira/browse/KAFKA-791 Project: Kafka Issue Type: Bug Reporter: Jo

[jira] [Commented] (KAFKA-104) Invalid topics prevent broker start-up

2013-03-05 Thread Colin B. (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13594131#comment-13594131 ] Colin B. commented on KAFKA-104: I am unable to reproduce this issue. It is likely this wa

[jira] [Updated] (KAFKA-786) Use "withRequiredArg" while parsing jopt options in all tools

2013-03-05 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-786: Attachment: kafka-786-v2.patch Jun raised a good question: What do we do for options like "print" or

[jira] [Updated] (KAFKA-787) Simple Consumer connecting to Broker that is not the Leader generates wrong error

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-787: Attachment: kafka-787.patch Minor fix for the correct error code > Simple Consumer

[jira] [Updated] (KAFKA-787) Simple Consumer connecting to Broker that is not the Leader generates wrong error

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-787: Status: Patch Available (was: Open) > Simple Consumer connecting to Broker that is not the Lead

[jira] [Commented] (KAFKA-784) creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic'

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13594069#comment-13594069 ] Neha Narkhede commented on KAFKA-784: - The delete topic functionality is not yet implem

[jira] [Updated] (KAFKA-782) replicas not being displayed in TopicMetadataResponse when replica's Broker is shutdown

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-782: Labels: kafka-0.8 p2 (was: ) > replicas not being displayed in TopicMetadataResponse when repli

[jira] [Updated] (KAFKA-783) Preferred replica assignment on leader failure may not be correct

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-783: Labels: kafka-0.8 p2 (was: ) > Preferred replica assignment on leader failure may not be correc

[jira] [Assigned] (KAFKA-783) Preferred replica assignment on leader failure may not be correct

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-783: --- Assignee: Sriram Subramanian (was: Neha Narkhede) Related to the preferred replica tool tests

[jira] [Created] (KAFKA-790) Kafka server throws UnknownTopicOrPartitionException right after becoming leader for a new partition

2013-03-05 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-790: --- Summary: Kafka server throws UnknownTopicOrPartitionException right after becoming leader for a new partition Key: KAFKA-790 URL: https://issues.apache.org/jira/browse/KAFKA-790

[jira] [Updated] (KAFKA-790) Kafka server throws UnknownTopicOrPartitionException right after becoming leader for a new partition

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-790: Labels: kafka-0.8 p1 (was: ) > Kafka server throws UnknownTopicOrPartitionException right after

[jira] [Created] (KAFKA-789) Producer-side persistence for delivery guarantee

2013-03-05 Thread Matan Safriel (JIRA)
Matan Safriel created KAFKA-789: --- Summary: Producer-side persistence for delivery guarantee Key: KAFKA-789 URL: https://issues.apache.org/jira/browse/KAFKA-789 Project: Kafka Issue Type: Improv

[jira] [Assigned] (KAFKA-788) Periodic refresh of topic metadata on the producer doesn't include all topics

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-788: --- Assignee: Neha Narkhede (was: Jun Rao) > Periodic refresh of topic metadata on the produc

[jira] [Created] (KAFKA-788) Periodic refresh of topic metadata on the producer doesn't include all topics

2013-03-05 Thread Neha Narkhede (JIRA)
Neha Narkhede created KAFKA-788: --- Summary: Periodic refresh of topic metadata on the producer doesn't include all topics Key: KAFKA-788 URL: https://issues.apache.org/jira/browse/KAFKA-788 Project: Kafk

[jira] [Commented] (KAFKA-496) high level producer send should return a response

2013-03-05 Thread Matan Safriel (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13593775#comment-13593775 ] Matan Safriel commented on KAFKA-496: - I spent some time trying to first-iteration-refa

[jira] [Closed] (KAFKA-780) Reassign partitions tool produces NPE in shutdown handler

2013-03-05 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian closed KAFKA-780. > Reassign partitions tool produces NPE in shutdown handler > --

[jira] [Resolved] (KAFKA-780) Reassign partitions tool produces NPE in shutdown handler

2013-03-05 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian resolved KAFKA-780. -- Resolution: Fixed Resolved by KAFKA-785 > Reassign partitions tool prod

[jira] [Closed] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-785. --- > Resolve bugs in PreferredReplicaLeaderElection admin tool >

[jira] [Resolved] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-785. - Resolution: Fixed Checked in. > Resolve bugs in PreferredReplicaLeaderElection ad

[jira] [Commented] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13593643#comment-13593643 ] Neha Narkhede commented on KAFKA-785: - +1 > Resolve bugs in PreferredR

[jira] [Assigned] (KAFKA-787) Simple Consumer connecting to Broker that is not the Leader generates wrong error

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-787: --- Assignee: Neha Narkhede > Simple Consumer connecting to Broker that is not the Leader gene

[jira] [Updated] (KAFKA-787) Simple Consumer connecting to Broker that is not the Leader generates wrong error

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-787: Labels: kafka-0.8 p2 (was: ) > Simple Consumer connecting to Broker that is not the Leader gene

[jira] [Created] (KAFKA-787) Simple Consumer connecting to Broker that is not the Leader generates wrong error

2013-03-05 Thread Chris Curtin (JIRA)
Chris Curtin created KAFKA-787: -- Summary: Simple Consumer connecting to Broker that is not the Leader generates wrong error Key: KAFKA-787 URL: https://issues.apache.org/jira/browse/KAFKA-787 Project: Ka

[jira] [Resolved] (KAFKA-105) switch to using slf4j

2013-03-05 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-105. --- Resolution: Won't Fix Since we now have the Logger class, which gives us most of the benefits of slf4j api, w

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

2013-03-05 Thread Neha Narkhede
The problem is that you need to invoke getData, not getChildren on this path - /brokers/topics/test-topic/1. That will return the # of partitions on this broker, which is 1. Thanks, Neha On Tue, Mar 5, 2013 at 6:48 AM, sourabh chaki wrote: > Hi Neha, > > Thanks for your reply. > > ZkClient zk =

[jira] [Commented] (KAFKA-772) System Test Transient Failure on testcase_0122

2013-03-05 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13593540#comment-13593540 ] Neha Narkhede commented on KAFKA-772: - Yeah, probably ok to skip the message

[jira] [Commented] (KAFKA-739) Handle null values in Message payload

2013-03-05 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13593523#comment-13593523 ] Jay Kreps commented on KAFKA-739: - No, actually it is just git diff against the base revisi

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

2013-03-05 Thread sourabh chaki
Hi Neha, Thanks for your reply. ZkClient zk = new ZkClient(serverstring ); List partitions = zk.getChildren("/brokers/topics/test-topic/1"); // my topic = test-topic, broker id = 1 This broker is associated with partition 0. So I am expecting output should be [0] but I am getting empty response