[jira] [Commented] (KAFKA-802) Flush message interval is based on compressed message count

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13600809#comment-13600809 ] Jun Rao commented on KAFKA-802: --- This is easy to fix on the leader since it iterates uncompre

[jira] [Created] (KAFKA-802) Flush message interval is based on compressed message count

2013-03-12 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-802: - Summary: Flush message interval is based on compressed message count Key: KAFKA-802 URL: https://issues.apache.org/jira/browse/KAFKA-802 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-801) Fix MessagesInPerSec mbean to count uncompressed message rate

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-801: -- Status: Patch Available (was: In Progress) Attach a patch. > Fix MessagesInPerSec mbean to cou

[jira] [Work started] (KAFKA-801) Fix MessagesInPerSec mbean to count uncompressed message rate

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-801 started by Jun Rao. > Fix MessagesInPerSec mbean to count uncompressed message rate > - > >

[jira] [Updated] (KAFKA-801) Fix MessagesInPerSec mbean to count uncompressed message rate

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-801: -- Attachment: kafka-801.patch > Fix MessagesInPerSec mbean to count uncompressed message rate > --

[jira] [Updated] (KAFKA-763) Add an option to replica from the largest offset during unclean leader election

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

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

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-779. --- > Standardize Zk data structures for Re-assign partitions and Preferred > replication election >

[jira] [Updated] (KAFKA-763) Add an option to replica from the largest offset during unclean leader election

2013-03-12 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-763: Attachment: kafka-763-new-v2.patch 1. Moved earliestOrLatestOffset to SimpleConsumer class. Checking

[jira] [Assigned] (KAFKA-801) Fix MessagesInPerSec mbean to count uncompressed message rate

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reassigned KAFKA-801: --- Assignee: Jun Rao (was: Neha Narkhede) > Fix MessagesInPerSec mbean to count uncompressed

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

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-790. --- > Kafka server throws UnknownTopicOrPartitionException right after becoming > leader for a new partit

[jira] [Updated] (KAFKA-795) Improvements to PreferredReplicaLeaderElection tool

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-795: Labels: (was: kafka-0.8 p2) > Improvements to PreferredReplicaLeaderElection tool > --

[jira] [Updated] (KAFKA-795) Improvements to PreferredReplicaLeaderElection tool

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-795: Priority: Major (was: Blocker) > Improvements to PreferredReplicaLeaderElection tool >

[jira] [Closed] (KAFKA-800) inSyncReplica in Partition needs some tweaks

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-800. --- > inSyncReplica in Partition needs some tweaks > > >

[jira] [Resolved] (KAFKA-800) inSyncReplica in Partition needs some tweaks

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-800. - Resolution: Fixed v2 checked in > inSyncReplica in Partition needs some tweaks >

[jira] [Commented] (KAFKA-800) inSyncReplica in Partition needs some tweaks

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13600287#comment-13600287 ] Neha Narkhede commented on KAFKA-800: - +1 on v2 > inSyncReplica in Par

[jira] [Updated] (KAFKA-800) inSyncReplica in Partition needs some tweaks

2013-03-12 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-800: - Attachment: KAFKA-800-v2.patch You are right. I was being too paranoid there.

[jira] [Commented] (KAFKA-800) inSyncReplica in Partition needs some tweaks

2013-03-12 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13600276#comment-13600276 ] Neha Narkhede commented on KAFKA-800: - Thanks for the patch, a few questions/comments -

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

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13600222#comment-13600222 ] Jun Rao commented on KAFKA-739: --- Thanks for patch v5. +1. > Handle null valu

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

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13600218#comment-13600218 ] Jun Rao commented on KAFKA-554: --- For debugging purpose, is it useful to be able to get the ru

[jira] [Commented] (KAFKA-800) inSyncReplica in Partition needs some tweaks

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13600207#comment-13600207 ] Jun Rao commented on KAFKA-800: --- Thanks for the patch. Just one comment. 1. ReplicaManager:

[jira] [Updated] (KAFKA-800) inSyncReplica in Partition needs some tweaks

2013-03-12 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-800: - Attachment: KAFKA-800.patch > inSyncReplica in Partition needs some tweaks > -

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

2013-03-12 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] [Updated] (KAFKA-739) Handle null values in Message payload

2013-03-12 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-739: Attachment: KAFKA-739-v5.patch Jun, attached v5 patch to address your comments. 40. This is actually right,

[jira] [Commented] (KAFKA-763) Add an option to replica from the largest offset during unclean leader election

2013-03-12 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13600157#comment-13600157 ] Jun Rao commented on KAFKA-763: --- Thanks for the patch. Some comments: 1. We should try to re