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

[ 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-corrected.patch Does it work now? > Add state change log t

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

I didn't check before I typed. I was referring to readData(). Thanks, Neha On Tue, Mar 5, 2013 at 11:04 PM, sourabh chaki wrote: > 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 > > >

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

[ 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

Apache Kafka git unavailable this morning

Hi, It seems that git push or pull hang on Apache Kafka git repo this morning. Could you help? Thanks, Jun

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

[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-513. - Resolution: Fixed Thanks for patch v5 Swapnil, the state change log looks great! I checked in tha

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

[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-513. --- > Add state change log to Kafka brokers > - > > Ke

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

[ https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-786. --- Resolution: Fixed Fix Version/s: 0.8 Thanks for the patch. Committed to 0.8. > Use "wi

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

[ https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-786. --- > Use "withRequiredArg" while parsing jopt options in all tools >

Re: Apache Kafka git unavailable this morning

Should work now Jun Rao wrote on Wed, Mar 06, 2013 at 09:34:34 -0800: > Hi, > > It seems that git push or pull hang on Apache Kafka git repo this morning. > Could you help? > > Thanks, > > Jun

Re: Apache Kafka git unavailable this morning

Thanks, Daniel. It works now. Jun On Wed, Mar 6, 2013 at 10:02 AM, Daniel Shahaf wrote: > Should work now > > Jun Rao wrote on Wed, Mar 06, 2013 at 09:34:34 -0800: > > Hi, > > > > It seems that git push or pull hang on Apache Kafka git repo this > morning. > > Could you help? > > > > Thanks, > >

[jira] [Commented] (KAFKA-779) Standardize Zk data structures for Re-assign partitions and Preferred replication election

[ https://issues.apache.org/jira/browse/KAFKA-779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13594965#comment-13594965 ] Jun Rao commented on KAFKA-779: --- Thanks for patch v2. Looks good overall. A couple of comment

[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=13594912#comment-13594912 ] Jun Rao commented on KAFKA-513: --- Thanks for the patch. A couple of more comments: 50. We add

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

[ https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13595011#comment-13595011 ] Neha Narkhede commented on KAFKA-739: - There was a conflict on DefaultEventHandler, but

[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=13595025#comment-13595025 ] Swapnil Ghike commented on KAFKA-513: - Thanks for making the corrections Neha. Jun: Pe

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

Thanks Neha for your response. Now I am calling it like: List partitions = zkclient.readData("/brokers/topics/test-topic/1"); //topic = test topic and broker id is 1 *1. * Now _connection.readData(path, stat, watch); is returning a byte[] of [49]. But derializable(data) is throwing ZkMarshal

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

You can instantiate ZkClient with the ZkStringSerializer in Kafka - zkClient = new ZkClient(params.zkConnect, 3, 3, ZKStringSerializer) For code examples on how to read the various paths, you can take a look at kafka.utils.ZkUtils.scala Thanks, Neha On Wed, Mar 6, 2013 at 11:43 AM

[jira] [Updated] (KAFKA-779) Standardize Zk data structures for Re-assign partitions and Preferred replication election

[ https://issues.apache.org/jira/browse/KAFKA-779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-779: Attachment: kafka-779-v3.patch Patch v3: 1. Ok, not asking the user to provide version in both the

[jira] [Commented] (KAFKA-554) Move all per-topic configuration into ZK and add to the CreateTopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13595090#comment-13595090 ] Neha Narkhede commented on KAFKA-554: - I'm a little late to this review and seems like

[jira] [Resolved] (KAFKA-779) Standardize Zk data structures for Re-assign partitions and Preferred replication election

[ https://issues.apache.org/jira/browse/KAFKA-779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-779. --- Resolution: Fixed Thanks for patch v3. Committed to 0.8. > Standardize Zk data structures for

[jira] [Created] (KAFKA-793) Include controllerId in all requests sent by controller

Swapnil Ghike created KAFKA-793: --- Summary: Include controllerId in all requests sent by controller Key: KAFKA-793 URL: https://issues.apache.org/jira/browse/KAFKA-793 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-732) MirrorMaker with shallow.iterator.enable=true produces unreadble messages

[ https://issues.apache.org/jira/browse/KAFKA-732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-732: -- Attachment: kafka-732.patch Attach a patch that removes the shallow iteration option in the consumer.

[jira] [Updated] (KAFKA-732) MirrorMaker with shallow.iterator.enable=true produces unreadble messages

[ https://issues.apache.org/jira/browse/KAFKA-732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-732: -- Assignee: Jun Rao (was: Neha Narkhede) Status: Patch Available (was: Open) > MirrorMaker with shallo

[jira] [Commented] (KAFKA-732) MirrorMaker with shallow.iterator.enable=true produces unreadble messages

[ https://issues.apache.org/jira/browse/KAFKA-732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13595298#comment-13595298 ] Neha Narkhede commented on KAFKA-732: - +1 > MirrorMaker with shallow.i

[jira] [Updated] (KAFKA-732) MirrorMaker with shallow.iterator.enable=true produces unreadble messages

[ https://issues.apache.org/jira/browse/KAFKA-732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-732: -- Resolution: Fixed Fix Version/s: 0.8 Status: Resolved (was: Patch Available) Thanks for the r

[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=13595339#comment-13595339 ] Jason Rosenberg commented on KAFKA-330: --- I'd also like to see an auto-delete feature,

[jira] [Updated] (KAFKA-793) Include controllerId in all requests sent by controller

[ https://issues.apache.org/jira/browse/KAFKA-793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-793: Labels: kafka-0.8 p1 (was: ) > Include controllerId in all requests sent by controller > --