[jira] [Updated] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

2013-01-16 Thread Maxime Brugidou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-693: -- Attachment: KAFKA-693-v2.patch Consumer rebalance fails if no leader available for a

[jira] [Commented] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

2013-01-16 Thread Maxime Brugidou (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13554852#comment-13554852 ] Maxime Brugidou commented on KAFKA-693: --- 10. Created PartitionTopicInfo.InvalidOffset

[jira] [Created] (KAFKA-706) broker appears to be encoding ProduceResponse, but never sending it

2013-01-16 Thread ben fleis (JIRA)
ben fleis created KAFKA-706: --- Summary: broker appears to be encoding ProduceResponse, but never sending it Key: KAFKA-706 URL: https://issues.apache.org/jira/browse/KAFKA-706 Project: Kafka Issue

[jira] [Commented] (KAFKA-649) Cleanup log4j logging

2013-01-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555150#comment-13555150 ] Jun Rao commented on KAFKA-649: --- I can take a look at this. Cleanup log4j

[jira] [Assigned] (KAFKA-649) Cleanup log4j logging

2013-01-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-649: - Assignee: Jun Rao Cleanup log4j logging - Key: KAFKA-649

[jira] [Commented] (KAFKA-631) Implement log compaction

2013-01-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555154#comment-13555154 ] Jun Rao commented on KAFKA-631: --- Thanks for the patch. Do you know the revision of trunk on

[jira] [Commented] (KAFKA-702) Deadlock between request handler/processor threads

2013-01-16 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555219#comment-13555219 ] Sriram Subramanian commented on KAFKA-702: -- I would like to add my thoughts to

[jira] [Commented] (KAFKA-693) Consumer rebalance fails if no leader available for a partition and stops all fetchers

2013-01-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555251#comment-13555251 ] Jun Rao commented on KAFKA-693: --- Thanks for patch v2. Looks good. Some minor comments: 11. I

[jira] [Resolved] (KAFKA-702) Deadlock between request handler/processor threads

2013-01-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-702. - Resolution: Fixed Checked this in to proceed with deployment Deadlock between

[jira] [Commented] (KAFKA-702) Deadlock between request handler/processor threads

2013-01-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555350#comment-13555350 ] Neha Narkhede commented on KAFKA-702: - 2. Having client quotas may not work because we

[jira] [Commented] (KAFKA-705) Controlled shutdown doesn't seem to work on more than one broker in a cluster

2013-01-16 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555352#comment-13555352 ] Joel Koshy commented on KAFKA-705: -- I set up a local cluster of three brokers and created

[jira] [Commented] (KAFKA-631) Implement log compaction

2013-01-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555470#comment-13555470 ] Jay Kreps commented on KAFKA-631: - 362eba981de40a69ae509a291649531ead6f6aee

[jira] [Closed] (KAFKA-702) Deadlock between request handler/processor threads

2013-01-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-702. --- Deadlock between request handler/processor threads

[jira] [Updated] (KAFKA-691) Fault tolerance broken with replication factor 1

2013-01-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-691: -- Attachment: kafka-691_extra.patch The last patch introduced a bug. DefaultEventHander.getPartition() is

[jira] [Updated] (KAFKA-691) Fault tolerance broken with replication factor 1

2013-01-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-691: -- Attachment: kafka-691_extra.patch Attach the right patch (kafka-691_extra.patch). Fault

[jira] [Created] (KAFKA-708) ISR becomes empty while marking a partition offline

2013-01-16 Thread Swapnil Ghike (JIRA)
Swapnil Ghike created KAFKA-708: --- Summary: ISR becomes empty while marking a partition offline Key: KAFKA-708 URL: https://issues.apache.org/jira/browse/KAFKA-708 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-708) ISR becomes empty while marking a partition offline

2013-01-16 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike reassigned KAFKA-708: --- Assignee: Neha Narkhede ISR becomes empty while marking a partition offline

[jira] [Created] (KAFKA-709) Default queue.enqueue.timeout.ms to -1

2013-01-16 Thread Chris Riccomini (JIRA)
Chris Riccomini created KAFKA-709: - Summary: Default queue.enqueue.timeout.ms to -1 Key: KAFKA-709 URL: https://issues.apache.org/jira/browse/KAFKA-709 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-709) Default queue.enqueue.timeout.ms to -1

2013-01-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13555782#comment-13555782 ] Jay Kreps commented on KAFKA-709: - Yeah I agree. Everyone who tries to use it hits this and

dynamic topic config

2013-01-16 Thread Jay Kreps
I added a first pass at a proposal for moving topic configuration into zookeeper so that you would specify the config when you created the topic and config could be altered without bouncing brokers. I think other people know more about the zookeeper interaction so I probably need help working out

Abou Kafka 0.8 producer throughput test

2013-01-16 Thread Jun Guo -X (jungu - CIIC at Cisco)
Hi, I do producer(Kafka 0.8) throughput test many times. But the average value is 3MB/S. Below is my test environment: CPU core :16 Vendor_id ：GenuineIntel Cpu family ：6 Cpu MHz :2899.999 Cache size:20480 KB Cpu level :13

[jira] [Assigned] (KAFKA-709) Default queue.enqueue.timeout.ms to -1

2013-01-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-709: --- Assignee: Neha Narkhede (was: Jun Rao) Default queue.enqueue.timeout.ms to -1

[jira] [Updated] (KAFKA-707) Improve error message in the producer when sending data to a partition without an active leader

2013-01-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-707: Attachment: kafka-707.patch Minor patch to fix the error message in the producer