[jira] [Commented] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13576408#comment-13576408 ] Sriram Subramanian commented on KAFKA-756: -- There are two parts to this change. 1

[jira] [Commented] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13576357#comment-13576357 ] Jay Kreps commented on KAFKA-756: - I don't understand the intention of the mutlisend change

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

2013-02-11 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-v2.patch Patch v2: 1.1.a Statements other than "abort transition" are logged

Re: Typo's...

2013-02-11 Thread Jun Rao
Netz, Thanks a lot. I just updated the site with those changes. Jun On Thu, Feb 7, 2013 at 10:17 PM, Nelz wrote: > Hello, > > I was recently doing some reading of your materials, and I found a > couple of typo's. In the spirit of Open Source, I thought I'd just jot > a quick note for the bette

[jira] [Commented] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13576271#comment-13576271 ] Jun Rao commented on KAFKA-756: --- Thanks for patch v2. Looks good overall. A few minor comment

[jira] [Updated] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-756: - Attachment: Kafka-756-v2.patch > Processor thread blocks due to infinite loop during f

[jira] [Updated] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-756: - Attachment: (was: Kafka-756-v2.patch) > Processor thread blocks due to infinite lo

[jira] [Updated] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-756: - Attachment: Kafka-756-v2.patch writeTo of multiSend is modified to keep writing till we ca

[jira] [Commented] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13576216#comment-13576216 ] Sriram Subramanian commented on KAFKA-756: -- - Ignore the second change. Will have

[jira] [Updated] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-756: - Attachment: KAFKA-756.patch This does two things - Checks during writeTo in FileMessageSet

[jira] [Created] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
Sriram Subramanian created KAFKA-756: Summary: Processor thread blocks due to infinite loop during fetch response send Key: KAFKA-756 URL: https://issues.apache.org/jira/browse/KAFKA-756 Project:

[jira] [Updated] (KAFKA-756) Processor thread blocks due to infinite loop during fetch response send

2013-02-11 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-756: - Labels: bugs p1 (was: ) > Processor thread blocks due to infinite loop during fetch r

Re: admin functionality refactoring

2013-02-11 Thread S Ahmed
I think that is eating too much of your dog food :) On Mon, Feb 11, 2013 at 3:08 PM, Jay Kreps wrote: > One thought I had on some of these things was that it is actually kind of > funny that we implement them in zookeeper. Technically we could implement > them in Kafka itself which would mean l

Re: admin functionality refactoring

2013-02-11 Thread Jay Kreps
One thought I had on some of these things was that it is actually kind of funny that we implement them in zookeeper. Technically we could implement them in Kafka itself which would mean less code (potentially) and also a clean api to clients. The idea is that many of the admin apis are basically c

[jira] [Commented] (KAFKA-755) standardizing json values stored in ZK

2013-02-11 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13576062#comment-13576062 ] Jay Kreps commented on KAFKA-755: - Also c. Think through how any generalization would work

[jira] Subscription: outstanding kafka patches

2013-02-11 Thread jira
Issue Subscription Filter: outstanding kafka patches (60 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-751 Fix windows build script - kafka-run-class.bat https://issues.apache.org/jira/browse/KAFKA-751 KAFKA-745 Remov

[jira] [Created] (KAFKA-755) standardizing json values stored in ZK

2013-02-11 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-755: - Summary: standardizing json values stored in ZK Key: KAFKA-755 URL: https://issues.apache.org/jira/browse/KAFKA-755 Project: Kafka Issue Type: Bug Components: co

Re: Kafka Cluster issue..

2013-02-11 Thread Jun Rao
There is a known bug in Kafka 0.7.x. Basically, for a new topic, we bootstrap using all existing brokers. However, if a topic already exists on some brokers, we never bootstrap again, which means new brokers will be ignored. For now, you have to manually create the topic on the new brokers (e.g., b

Clients and replica leaders

2013-02-11 Thread David Arthur
In writing a client for 0.8, I now have to keep state of which topic+partition is owned by what broker. This is inherently a pain to deal with and has the downside that I must wait for an error before I am notified about a change in the broker topology. I would be nice if the clients didn't ne