[jira] [Updated] (KAFKA-646) Provide aggregate stats at the high level Producer and ZookeeperConsumerConnector level

[ https://issues.apache.org/jira/browse/KAFKA-646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-646: Attachment: kafka-646-patch-num1-v6.patch Made the changes. Provide aggregate

can't commit to Kafka svn

Hi, I can't seem to commit to Kafka svn since this morning. The commit is on a fresh checkout. Do you know what the issue is? jrao-mn:0.8_top_temp jrao$ svn commit --username junrao -m trivial fix to increase offset commit interval to reduce ZK load Sending

[jira] [Created] (KAFKA-670) Cleanup spurious .index files if present in the log directory on initialization

Jay Kreps created KAFKA-670: --- Summary: Cleanup spurious .index files if present in the log directory on initialization Key: KAFKA-670 URL: https://issues.apache.org/jira/browse/KAFKA-670 Project: Kafka

[jira] [Updated] (KAFKA-670) Cleanup spurious .index files if present in the log directory on initialization

[ https://issues.apache.org/jira/browse/KAFKA-670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-670: Priority: Blocker (was: Major) Cleanup spurious .index files if present in the log directory on

[jira] [Commented] (KAFKA-604) Add missing metrics in 0.8

[ https://issues.apache.org/jira/browse/KAFKA-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530165#comment-13530165 ] Joel Koshy commented on KAFKA-604: -- The rebased patch does not really comment on/address

[jira] [Commented] (KAFKA-657) Add an API to commit offsets

[ https://issues.apache.org/jira/browse/KAFKA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530174#comment-13530174 ] David Arthur commented on KAFKA-657: Thanks [~jkreps], that clears things up quite a

[jira] [Updated] (KAFKA-669) Irrecoverable error on leader while rolling to a new segment

[ https://issues.apache.org/jira/browse/KAFKA-669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-669: Labels: bugs (was: replication-performance) Irrecoverable error on leader while rolling to a

[jira] [Updated] (KAFKA-669) Irrecoverable error on leader while rolling to a new segment

[ https://issues.apache.org/jira/browse/KAFKA-669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-669: Summary: Irrecoverable error on leader while rolling to a new segment (was: Kafka server sends

[jira] [Updated] (KAFKA-669) Irrecoverable error on leader while rolling to a new segment

[ https://issues.apache.org/jira/browse/KAFKA-669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-669: Description: I setup a test cluster of 5 brokers and setup migration tool to send data for ~1000

[jira] [Commented] (KAFKA-604) Add missing metrics in 0.8

[ https://issues.apache.org/jira/browse/KAFKA-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530200#comment-13530200 ] Swapnil Ghike commented on KAFKA-604: - Yes I like this idea, can follow this in

[jira] [Updated] (KAFKA-669) Irrecoverable error on leader while rolling to a new segment

[ https://issues.apache.org/jira/browse/KAFKA-669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-669: Description: I setup a test cluster of 5 brokers and setup migration tool to send data for ~1000

[jira] [Updated] (KAFKA-646) Provide aggregate stats at the high level Producer and ZookeeperConsumerConnector level

[ https://issues.apache.org/jira/browse/KAFKA-646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-646: Attachment: kafka-646-patch-num1-v7.patch Including in patch v7 Joel's suggestion at KAFKA-604 to

[jira] [Commented] (KAFKA-604) Add missing metrics in 0.8

[ https://issues.apache.org/jira/browse/KAFKA-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530223#comment-13530223 ] Yang Ye commented on KAFKA-604: --- Joel, thanks for the idea, it's good and I will do a new

[jira] [Updated] (KAFKA-664) Kafka server threads die due to OOME during long running test

[ https://issues.apache.org/jira/browse/KAFKA-664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-664: - Attachment: KAFKA-664-v3.patch Here is a simpler and hopefully safer approach of using a global request

[jira] [Commented] (KAFKA-624) Add 07 ConsoleConsumer to validate message content for Migration Tool testcases

[ https://issues.apache.org/jira/browse/KAFKA-624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530232#comment-13530232 ] John Fung commented on KAFKA-624: - Currently, the migration tool testcases (9001 ~ 9006)

[jira] [Commented] (KAFKA-624) Add 07 ConsoleConsumer to validate message content for Migration Tool testcases

[ https://issues.apache.org/jira/browse/KAFKA-624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530244#comment-13530244 ] John Fung commented on KAFKA-624: - The 07 ProducerPerformance produces messages with random

[jira] [Created] (KAFKA-671) DelayedProduce requests should not hold full producer request data

Joel Koshy created KAFKA-671: Summary: DelayedProduce requests should not hold full producer request data Key: KAFKA-671 URL: https://issues.apache.org/jira/browse/KAFKA-671 Project: Kafka

[jira] [Commented] (KAFKA-664) Kafka server threads die due to OOME during long running test

[ https://issues.apache.org/jira/browse/KAFKA-664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530254#comment-13530254 ] Joel Koshy commented on KAFKA-664: -- Also, just filed KAFKA-671 to address the issue that

[jira] [Updated] (KAFKA-670) Cleanup spurious .index files if present in the log directory on initialization

[ https://issues.apache.org/jira/browse/KAFKA-670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-670: Attachment: KAFKA-670-v1.patch Cleanup any bogus index files (those without a corresponding .log file)

[jira] [Commented] (KAFKA-330) Add delete topic support

[ https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530293#comment-13530293 ] Sam Meder commented on KAFKA-330: - I've been doing a lot of manual resetting of data in

[jira] [Created] (KAFKA-672) Merge 0.8 changes to trunk

Jay Kreps created KAFKA-672: --- Summary: Merge 0.8 changes to trunk Key: KAFKA-672 URL: https://issues.apache.org/jira/browse/KAFKA-672 Project: Kafka Issue Type: Bug Reporter: Jay Kreps

[jira] [Updated] (KAFKA-672) Merge 0.8 changes to trunk

[ https://issues.apache.org/jira/browse/KAFKA-672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-672: Attachment: KAFKA-672.patch Here is the merge changes in case anyone wants to take a look. I will probably

[jira] [Commented] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests

[ https://issues.apache.org/jira/browse/KAFKA-626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530526#comment-13530526 ] Neha Narkhede commented on KAFKA-626: - Correct. The right fix is to forward the request

[jira] [Resolved] (KAFKA-626) Produce requests dropped due to socket timeouts on get metadata requests

[ https://issues.apache.org/jira/browse/KAFKA-626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-626. - Resolution: Fixed Assignee: Neha Narkhede Produce requests dropped due to socket

[jira] [Updated] (KAFKA-513) Add state change log to Kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-513: Attachment: kafka-513-v1.patch Patch v1: 1. Created a tool PartitionStateChangeLogMerger - It looks

[jira] [Commented] (KAFKA-374) Move to java CRC32 implementation

[ https://issues.apache.org/jira/browse/KAFKA-374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530654#comment-13530654 ] Scott Carey commented on KAFKA-374: --- Awesome. I was just profiling some Kafka 0.7.1

[jira] [Commented] (KAFKA-374) Move to java CRC32 implementation

[ https://issues.apache.org/jira/browse/KAFKA-374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530674#comment-13530674 ] Jay Kreps commented on KAFKA-374: - Hey Scott, currently the implementation of the consumer

[jira] [Commented] (KAFKA-669) Irrecoverable error on leader while rolling to a new segment

[ https://issues.apache.org/jira/browse/KAFKA-669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530694#comment-13530694 ] Jay Kreps commented on KAFKA-669: - I don't see the source of the logging you added to print

[jira] [Commented] (KAFKA-657) Add an API to commit offsets

[ https://issues.apache.org/jira/browse/KAFKA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530700#comment-13530700 ] Jay Kreps commented on KAFKA-657: - I wonder if you could take a look at the updated docs

[jira] [Commented] (KAFKA-664) Kafka server threads die due to OOME during long running test

[ https://issues.apache.org/jira/browse/KAFKA-664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13530709#comment-13530709 ] Jun Rao commented on KAFKA-664: --- Thanks for patch v3. +1 from me. One minor comment: Should

Re: CRC patch

+1 on the code change looks alright, I prefer using the java version in this case only because we are using an implementation from another project and its a drop in ... no reason to change things without good reason, yup. On Wed, Dec 12, 2012 at 11:55 PM, Jay Kreps jay.kr...@gmail.com wrote: