[jira] [Commented] (KAFKA-574) KafkaController unnecessarily reads leaderAndIsr info from ZK

2012-10-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486091#comment-13486091 ] Jun Rao commented on KAFKA-574: --- Thanks for the patch. Some comments: 1.

[jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-583: Attachment: (was: run-simple-consumer.sh) SimpleConsumerShell may receive less data inconsistently

[jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-583: Attachment: (was: broker_log_segment_files.tar.gz) SimpleConsumerShell may receive less data

[jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-583: Attachment: (was: log4j_messages.tar.gz) SimpleConsumerShell may receive less data inconsistently

[jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-583: Attachment: kafka_583_reproduce_issue.patch SimpleConsumerShell may receive less data inconsistently

[jira] [Updated] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-583: Attachment: kafka_583_zk_kafka_data.tar.gz SimpleConsumerShell may receive less data inconsistently

[jira] [Commented] (KAFKA-583) SimpleConsumerShell may receive less data inconsistently

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486125#comment-13486125 ] John Fung commented on KAFKA-583: - This issue can be reproduced consistently using the

[jira] [Commented] (KAFKA-188) Support multiple data directories

2012-10-29 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486220#comment-13486220 ] Jay Kreps commented on KAFKA-188: - Okay, you and Neha are giving conflicting advice on

[jira] [Updated] (KAFKA-586) system test configs are broken

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-586: Attachment: kafka-586-v1.patch system test configs are broken --

[jira] [Comment Edited] (KAFKA-586) system test configs are broken

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13484696#comment-13484696 ] John Fung edited comment on KAFKA-586 at 10/29/12 6:47 PM: --- Hi

[jira] [Updated] (KAFKA-586) system test configs are broken

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-586: Status: Patch Available (was: Open) system test configs are broken --

[jira] [Commented] (KAFKA-586) system test configs are broken

2012-10-29 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486252#comment-13486252 ] John Fung commented on KAFKA-586: - Uploaded kafka-586-v1.patch which contains the latest

[jira] [Commented] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly

2012-10-29 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486293#comment-13486293 ] Jay Kreps commented on KAFKA-588: - Jun the OffsetIndex.truncateTo logic looks right to me

[jira] [Commented] (KAFKA-397) kafka.common.InvalidMessageSizeException: null

2012-10-29 Thread David Arthur (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486297#comment-13486297 ] David Arthur commented on KAFKA-397: Try cleaning out ZooKeeper as well as the Kafka

[jira] [Updated] (KAFKA-575) Partition.makeFollower() reads broker info from ZK

2012-10-29 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-575: Attachment: kafka-575-v2.patch Made the change. Partition.makeFollower() reads

[jira] [Commented] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload

2012-10-29 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486323#comment-13486323 ] Yang Ye commented on KAFKA-267: --- V6 should be the right one, please review this one

[jira] [Created] (KAFKA-591) Add test cases to test log size retention and more

2012-10-29 Thread John Fung (JIRA)
John Fung created KAFKA-591: --- Summary: Add test cases to test log size retention and more Key: KAFKA-591 URL: https://issues.apache.org/jira/browse/KAFKA-591 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index

2012-10-29 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-577: -- Attachment: kafka_577_v2.diff changed according to the comments extend DumpLogSegments to

[jira] [Assigned] (KAFKA-589) Clean shutdown after startup connection failure

2012-10-29 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike reassigned KAFKA-589: --- Assignee: Swapnil Ghike Clean shutdown after startup connection failure

[jira] [Commented] (KAFKA-589) Clean shutdown after startup connection failure

2012-10-29 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486378#comment-13486378 ] Swapnil Ghike commented on KAFKA-589: - Hi Jason, Are you using the

[jira] [Updated] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index

2012-10-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-577: -- Comment: was deleted (was: +1 on patch v6. Committed to 0.8.) extend DumpLogSegments to verify

[jira] [Updated] (KAFKA-188) Support multiple data directories

2012-10-29 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-188: Attachment: KAFKA-188-v6.patch Okay this patch addresses Jun's comments: 50. The zeros are actually

[jira] [Updated] (KAFKA-267) Enhance ProducerPerformance to generate unique random Long value for payload

2012-10-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-267: -- Resolution: Fixed Fix Version/s: 0.8 Status: Resolved (was: Patch Available) +1 on patch v6.

[jira] [Updated] (KAFKA-588) Index truncation doesn't seem to remove the last entry properly

2012-10-29 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-588: Attachment: KAFKA-588.patch I can't reproduce this issue, but this patch expands the tests and adds a

[jira] [Updated] (KAFKA-592) Register metrics beans at kafka server startup

2012-10-29 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-592: Attachment: kafka-592-v1.patch Change made to register AllTopicsProduceFailurePerSec,

[jira] [Updated] (KAFKA-593) Empty log index file created when it shouldn't be empty

2012-10-29 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-593: -- Attachment: kafka_583_zk_kafka_data.tar.gz Empty log index file created when it shouldn't be empty

[jira] [Commented] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index

2012-10-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486548#comment-13486548 ] Jun Rao commented on KAFKA-577: --- Thanks for patch v2. Instead of exiting on first

[jira] [Resolved] (KAFKA-575) Partition.makeFollower() reads broker info from ZK

2012-10-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-575. --- Resolution: Fixed Fix Version/s: 0.8 Thanks for patch v3. +1. Committed to 0.8.

[jira] [Closed] (KAFKA-575) Partition.makeFollower() reads broker info from ZK

2012-10-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-575. - Partition.makeFollower() reads broker info from ZK --

[jira] [Reopened] (KAFKA-577) extend DumpLogSegments to verify consistency btw data and index

2012-10-29 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reopened KAFKA-577: --- extend DumpLogSegments to verify consistency btw data and index

[jira] [Commented] (KAFKA-593) Empty log index file created when it shouldn't be empty

2012-10-29 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13486631#comment-13486631 ] Jay Kreps commented on KAFKA-593: - I am not sure that this is a bug. The index entries are