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

2013-01-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13564388#comment-13564388 ] Jun Rao commented on KAFKA-631: --- A few more comments: 73.

[jira] [Commented] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-01-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13564393#comment-13564393 ] Jun Rao commented on KAFKA-695: --- So, do you think the patch is ok or do you plan to provide a

[jira] [Commented] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-01-28 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13564485#comment-13564485 ] Neha Narkhede commented on KAFKA-695: - The LogRecoveryTest throws the following new

[jira] Subscription: outstanding kafka patches

2013-01-28 Thread jira
Issue Subscription Filter: outstanding kafka patches (61 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-737 System Test : Disable shallow.iterator in Mirror Maker test cases to make compression work correctly

urgent request for kafka 0.8

2013-01-28 Thread Jane Wang
I just updated my kafka 0.8 this morning. After that I am not able to run kafka any more. The error msg I got is for producer: 13/01/28 11:23:57 ERROR async.DefaultEventHandler: Failed to send messages java.lang.NoClassDefFoundError: org/xerial/snappy/SnappyOutputStream at

[jira] [Updated] (KAFKA-735) Add looping and JSON output for ConsumerOffsetChecker

2013-01-28 Thread Dave DeMaagd (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dave DeMaagd updated KAFKA-735: --- Labels: patch (was: ) Add looping and JSON output for ConsumerOffsetChecker

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

2013-01-28 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-631: Attachment: KAFKA-631-v8.patch Patch v8 includes Jun's comments. Specifically: Cleaner: 70.1 Nice catch.

[jira] [Updated] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-01-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-695: -- Attachment: kafka-695_v2.patch Attach patch v2. Simplified the logic a bit. ExpiredRequestReaper now checks if

[jira] [Updated] (KAFKA-738) correlationId is not set in FetchRequest in AbstractFetcherThread

2013-01-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-738: -- Attachment: kafka-738.patch Attach a patch. Yes, we have to create a new FetchRequestBuilder every time,

[jira] [Assigned] (KAFKA-738) correlationId is not set in FetchRequest in AbstractFetcherThread

2013-01-28 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-738: - Assignee: Jun Rao correlationId is not set in FetchRequest in AbstractFetcherThread

Re: urgent request for kafka 0.8

2013-01-28 Thread Jane Wang
Please ignore the previous email. I have found the library version and got the jar files. Thanks, Jane On Mon, Jan 28, 2013 at 11:30 AM, Jane Wang ja...@twitter.com wrote: I just updated my kafka 0.8 this morning. After that I am not able to run kafka any more. The error msg I got is for

[jira] [Commented] (KAFKA-738) correlationId is not set in FetchRequest in AbstractFetcherThread

2013-01-28 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13564887#comment-13564887 ] Swapnil Ghike commented on KAFKA-738: - I see. Actually the same issue is present in

[jira] [Updated] (KAFKA-695) Broker shuts down due to attempt to read a closed index file

2013-01-28 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-695: Resolution: Fixed Status: Resolved (was: Patch Available) Broker shuts down due to

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

2013-01-28 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13564944#comment-13564944 ] Neha Narkhede commented on KAFKA-631: - +1 on v9. Some minor changes before you check it

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

2013-01-28 Thread Jay Kreps (JIRA)
Jay Kreps created KAFKA-739: --- Summary: Handle null values in Message payload Key: KAFKA-739 URL: https://issues.apache.org/jira/browse/KAFKA-739 Project: Kafka Issue Type: Bug

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

2013-01-28 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps reassigned KAFKA-739: --- Assignee: Jay Kreps Handle null values in Message payload -

[jira] [Updated] (KAFKA-741) Improve log cleaning dedupe buffer efficiency

2013-01-28 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-741: Fix Version/s: 0.8.1 Assignee: Jay Kreps Issue Type: Improvement (was: Bug) Improve