[jira] [Created] (KAFKA-717) scala 2.10 build support

2013-01-21 Thread Viktor Taranenko (JIRA)
Viktor Taranenko created KAFKA-717: -- Summary: scala 2.10 build support Key: KAFKA-717 URL: https://issues.apache.org/jira/browse/KAFKA-717 Project: Kafka Issue Type: Improvement Co

[jira] [Commented] (KAFKA-708) ISR becomes empty while marking a partition offline

2013-01-21 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559334#comment-13559334 ] Jun Rao commented on KAFKA-708: --- Thanks for the patch. Overall, looks good. A couple of minor

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions and upgrade to SBT 0.12.1

2013-01-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559309#comment-13559309 ] Joe Stein commented on KAFKA-139: - i committed the changes so that the start script looks i

[jira] [Comment Edited] (KAFKA-139) cross-compile multiple Scala versions and upgrade to SBT 0.12.1

2013-01-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559282#comment-13559282 ] Joe Stein edited comment on KAFKA-139 at 1/22/13 1:53 AM: -- there a

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions and upgrade to SBT 0.12.1

2013-01-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559282#comment-13559282 ] Joe Stein commented on KAFKA-139: - there are 2 issues I am fixing now in kafka-run-class.sh

[jira] [Updated] (KAFKA-696) Fix toString() API for all requests to make logging easier to read

2013-01-21 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-696: - Attachment: cleanup-v2.patch 1. The reason why I did not do that was because ReplicaReques

[jira] [Created] (KAFKA-716) SimpleConsumerPerformance does not consume all available messages

2013-01-21 Thread John Fung (JIRA)
John Fung created KAFKA-716: --- Summary: SimpleConsumerPerformance does not consume all available messages Key: KAFKA-716 URL: https://issues.apache.org/jira/browse/KAFKA-716 Project: Kafka Issue Ty

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

2013-01-21 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-v4.patch Did some testing with multithreading, resulting in... Patch v4: 1. Bug: Log

[jira] [Updated] (KAFKA-570) Kafka should not need snappy jar at runtime

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-570: Labels: bugs p4 (was: bugs) > Kafka should not need snappy jar at runtime > ---

[jira] [Updated] (KAFKA-598) decouple fetch size from max message size

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-598: Labels: p4 (was: ) > decouple fetch size from max message size > --

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

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-513: Labels: p2 replication tools (was: replication tools) > Add state change log to Kafka brokers >

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

2013-01-21 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: Labels: p2 (was: ) > Broker shuts down due to attempt to read a closed index file > ---

[jira] [Updated] (KAFKA-714) ConsoleConsumer throws SocketTimeoutException when fetching topic metadata

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-714: Labels: bugs p1 (was: ) > ConsoleConsumer throws SocketTimeoutException when fetching topic met

[jira] [Updated] (KAFKA-700) log client ip when we log each request on the broker

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-700: Labels: p1 (was: ) > log client ip when we log each request on the broker > ---

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

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-671: Labels: bugs p1 (was: ) > DelayedProduce requests should not hold full producer request data >

[jira] [Updated] (KAFKA-649) Cleanup log4j logging

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-649: Labels: p4 (was: ) > Cleanup log4j logging > - > > Key: KAF

[jira] [Updated] (KAFKA-708) ISR becomes empty while marking a partition offline

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-708: Labels: bugs p1 (was: bugs) > ISR becomes empty while marking a partition offline > ---

[jira] [Updated] (KAFKA-708) ISR becomes empty while marking a partition offline

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-708: Attachment: kafka-708-v1.patch Changes in this patch include - 1. Allowing the isr list to be empty

[jira] [Work started] (KAFKA-708) ISR becomes empty while marking a partition offline

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-708 started by Neha Narkhede. > ISR becomes empty while marking a partition offline > --- > >

[jira] [Commented] (KAFKA-714) ConsoleConsumer throws SocketTimeoutException when fetching topic metadata

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559142#comment-13559142 ] Neha Narkhede commented on KAFKA-714: - +1 on Jun's patch > ConsoleCons

[jira] [Updated] (KAFKA-714) ConsoleConsumer throws SocketTimeoutException when fetching topic metadata

2013-01-21 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-714: -- Status: Patch Available (was: Open) > ConsoleConsumer throws SocketTimeoutException when fetching topic met

[jira] [Updated] (KAFKA-714) ConsoleConsumer throws SocketTimeoutException when fetching topic metadata

2013-01-21 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-714: -- Component/s: core Priority: Blocker (was: Critical) Affects Version/s: 0.8 A

[jira] [Updated] (KAFKA-714) ConsoleConsumer throws SocketTimeoutException when fetching topic metadata

2013-01-21 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-714: -- Attachment: kafka-714.patch Thanks for opening the jira. Attach a patch that allows socket timeout to be passed

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

2013-01-21 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-705: - Attachment: kafka-705-incremental-v2.patch Here is what I meant in my last comment. > Con

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

2013-01-21 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559121#comment-13559121 ] Joel Koshy commented on KAFKA-705: -- I committed the fix to 0.8 with a small edit: used the

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions and upgrade to SBT 0.12.1

2013-01-21 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559073#comment-13559073 ] Jun Rao commented on KAFKA-139: --- Joe, after your check in. I saw a couple of changes: (1) ./s

[jira] [Updated] (KAFKA-139) cross-compile multiple Scala versions and upgrade to SBT 0.12.1

2013-01-21 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-139: Resolution: Fixed Status: Resolved (was: Patch Available) added 2.8.2 and committed changes to 0.8

[jira] [Updated] (KAFKA-703) A fetch request in Fetch Purgatory can double count the bytes from the same delayed produce request

2013-01-21 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-703: Fix Version/s: (was: 0.8) 0.8.1 > A fetch request in Fetch Purgatory can double c

[jira] [Commented] (KAFKA-715) NumberFormatException in PartitionStateInfo

2013-01-21 Thread Chris Riccomini (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559021#comment-13559021 ] Chris Riccomini commented on KAFKA-715: --- Indeed, it does! > NumberFo

[jira] [Commented] (KAFKA-703) A fetch request in Fetch Purgatory can double count the bytes from the same delayed produce request

2013-01-21 Thread Sriram Subramanian (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559018#comment-13559018 ] Sriram Subramanian commented on KAFKA-703: -- Can we move this jira to the next vers

[jira] [Commented] (KAFKA-715) NumberFormatException in PartitionStateInfo

2013-01-21 Thread Swapnil Ghike (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559016#comment-13559016 ] Swapnil Ghike commented on KAFKA-715: - Looks like a duplicate of KAFKA-708

[jira] [Created] (KAFKA-715) NumberFormatException in PartitionStateInfo

2013-01-21 Thread Chris Riccomini (JIRA)
Chris Riccomini created KAFKA-715: - Summary: NumberFormatException in PartitionStateInfo Key: KAFKA-715 URL: https://issues.apache.org/jira/browse/KAFKA-715 Project: Kafka Issue Type: Bug

[jira] Subscription: outstanding kafka patches

2013-01-21 Thread jira
Issue Subscription Filter: outstanding kafka patches (60 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-714 ConsoleConsumer throws SocketTimeoutException when fetching topic metadata https://issues.apache.org/jira/brows

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

2013-01-21 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-v3.patch Attached patch v3. Two small changes: 1. Make memory usage more intuitive now

[jira] [Updated] (KAFKA-714) ConsoleConsumer throws SocketTimeoutException when fetching topic metadata

2013-01-21 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-714: Attachment: kafka-714-reproduce-issue.patch Uploaded kafka-714-reproduce-issue.patch to reproduce the issue.

[jira] [Created] (KAFKA-714) ConsoleConsumer throws SocketTimeoutException when fetching topic metadata

2013-01-21 Thread John Fung (JIRA)
John Fung created KAFKA-714: --- Summary: ConsoleConsumer throws SocketTimeoutException when fetching topic metadata Key: KAFKA-714 URL: https://issues.apache.org/jira/browse/KAFKA-714 Project: Kafka

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

2013-01-21 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13558971#comment-13558971 ] Jay Kreps commented on KAFKA-631: - I did some testing on the I/O throttling and verified th

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

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13558969#comment-13558969 ] Neha Narkhede commented on KAFKA-671: - Thinking about this a little more, the real prob

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

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13558946#comment-13558946 ] Neha Narkhede commented on KAFKA-671: - Nullifying the request object seems like a bigge

[jira] [Commented] (KAFKA-710) Some arguments are always set to default in ProducerPerformance

2013-01-21 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13558867#comment-13558867 ] Jun Rao commented on KAFKA-710: --- Just to clarify. The problem is that there are duplicated co

[jira] [Commented] (KAFKA-139) cross-compile multiple Scala versions and upgrade to SBT 0.12.1

2013-01-21 Thread derek (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13558843#comment-13558843 ] derek commented on KAFKA-139: - OK, 2.10.0 is going to be a non-starter at this point due to a n

[jira] [Updated] (KAFKA-707) Improve error message in the producer when sending data to a partition without an active leader

2013-01-21 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: Status: Patch Available (was: Open) > Improve error message in the producer when sending data t

[jira] [Closed] (KAFKA-707) Improve error message in the producer when sending data to a partition without an active leader

2013-01-21 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-707. --- > Improve error message in the producer when sending data to a partition > without an active leader >

[jira] [Updated] (KAFKA-707) Improve error message in the producer when sending data to a partition without an active leader

2013-01-21 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: Resolution: Fixed Status: Resolved (was: Patch Available) Thank you for the review