[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 >

[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-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 updated KAFKA-709: Attachment: kafka-709.patch Minor one liner change to fix the default for queue.enqueue.timeout.ms

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

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 s

[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-tabpanel&focusedCommentId=13555782#comment-13555782 ] Jay Kreps commented on KAFKA-709: - Yeah I agree. Everyone who tries to use it hits this and

[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] [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] [Updated] (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 updated KAFKA-708: Attachment: kafka-request.log.2013-01-16-15 > ISR becomes empty while marking a partition offlin

[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: Bug

[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: (was: kafka-691_extra.patch) > Fault tolerance broken with replication factor 1 > --

[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 toler

[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 expected

[jira] [Assigned] (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 reassigned KAFKA-707: --- Assignee: Neha Narkhede (was: Jun Rao) > Improve error message in the producer when sendi

[jira] [Created] (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)
Neha Narkhede created KAFKA-707: --- Summary: Improve error message in the producer when sending data to a partition without an active leader Key: KAFKA-707 URL: https://issues.apache.org/jira/browse/KAFKA-707

[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] [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-tabpanel&focusedCommentId=13555470#comment-13555470 ] Jay Kreps commented on KAFKA-631: - 362eba981de40a69ae509a291649531ead6f6aee

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

2013-01-16 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13555359#comment-13555359 ] Neha Narkhede commented on KAFKA-705: - >> Would you by any chance be able to provide a

[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-tabpanel&focusedCommentId=13555352#comment-13555352 ] Joel Koshy commented on KAFKA-705: -- I set up a local cluster of three brokers and created

[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-tabpanel&focusedCommentId=13555350#comment-13555350 ] Neha Narkhede commented on KAFKA-702: - >> 2. Having client quotas may not work because

[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 r

[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-tabpanel&focusedCommentId=13555251#comment-13555251 ] Jun Rao commented on KAFKA-693: --- Thanks for patch v2. Looks good. Some minor comments: 11. I

[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-tabpanel&focusedCommentId=13555219#comment-13555219 ] Sriram Subramanian commented on KAFKA-702: -- I would like to add my thoughts to thi

[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-tabpanel&focusedCommentId=13555154#comment-13555154 ] Jun Rao commented on KAFKA-631: --- Thanks for the patch. Do you know the revision of trunk on w

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

2013-01-16 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13555148#comment-13555148 ] Jun Rao commented on KAFKA-702: --- First of all, +1 on the simple patch. I think it solves the

[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-tabpanel&focusedCommentId=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] [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-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-tabpanel&focusedCommentId=13554852#comment-13554852 ] Maxime Brugidou commented on KAFKA-693: --- 10. Created PartitionTopicInfo.InvalidOffset

[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 parti