[jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication

2012-10-01 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-42: --- Attachment: kafka-42-v2.patch 1. ReassignPartitionsCommand: 1.1 Makes sense, changed that. 1.2 I thin

Re: Integration with AMQP

2012-10-01 Thread Jun Rao
William, We haven't really thought about this. What's the benefit of AMQP and how widely is it being adopted? Thanks, Jun On Mon, Oct 1, 2012 at 12:07 PM, William Henry wrote: > Hi, > > Has anyone looked at this email? Anyone care to express an opinion? > > It seems like Apache has ActiveMQ

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

2012-10-01 Thread Jonathan Creasy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13467419#comment-13467419 ] Jonathan Creasy commented on KAFKA-188: --- Yes please, I have the code done, and I even

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

2012-10-01 Thread Jonathan Creasy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13467419#comment-13467419 ] Jonathan Creasy edited comment on KAFKA-188 at 10/2/12 1:32 PM: -

[jira] [Commented] (KAFKA-340) ensure ISR has enough brokers during clean shutdown of a broker

2012-10-01 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13467380#comment-13467380 ] Joel Koshy commented on KAFKA-340: -- This may not be too difficult to implement, but tricky

[jira] [Updated] (KAFKA-509) server should shut down on encountering invalid highwatermark file

2012-10-01 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-509: -- Attachment: kafka_509_v2.diff For the 1st comment about FileWriter, I've checked it, it will create new file if

[jira] [Updated] (KAFKA-432) allow consumer to read from followers

2012-10-01 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-432: -- Attachment: kafka_432_v1.diff 1. removing the "ConsumerShell.scala" file 2. Use "replicaId" field in "FetchReq

[jira] [Resolved] (KAFKA-529) kafka.server.ReplicaFetcherThread: java.lang.IndexOutOfBoundsException

2012-10-01 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung resolved KAFKA-529. - Resolution: Fixed This cannot be reproduced any more with the fix from KAFKA-528. So mark this FIXED.

[jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py

2012-10-01 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-502: Attachment: kafka-502-v3.patch Uploaded kafka-502-v3.patch with additional changes on top of kafka-502-v2.p

[jira] [Commented] (KAFKA-509) server should shut down on encountering invalid highwatermark file

2012-10-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13467203#comment-13467203 ] Jun Rao commented on KAFKA-509: --- Also, related to HW, currently LogMananger doesn't recognize

[jira] [Commented] (KAFKA-537) expose clientId and correlationId in ConsumerConfig

2012-10-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13467196#comment-13467196 ] Jun Rao commented on KAFKA-537: --- In this jira, we can probably also log the client id when hi

[jira] [Commented] (KAFKA-532) Multiple controllers can co-exist during soft failures

2012-10-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13467184#comment-13467184 ] Jun Rao commented on KAFKA-532: --- Thanks for patch v1. Some comments: 1. PartitionStateMachine

Re: Integration with AMQP

2012-10-01 Thread William Henry
Hi, Has anyone looked at this email? Anyone care to express an opinion? It seems like Apache has ActiveMQ and Qpid, which are already working on integrating, and now Kafka. Kafka might benefit by using Qpid/Proton just as ActiveMQ is trying to integrate with Qpid/Proton. If folks are interest

[jira] [Comment Edited] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py

2012-10-01 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13465896#comment-13465896 ] John Fung edited comment on KAFKA-502 at 10/2/12 5:05 AM: -- kafka-5

[jira] [Comment Edited] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py

2012-10-01 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13467010#comment-13467010 ] John Fung edited comment on KAFKA-502 at 10/2/12 5:03 AM: -- Uploade

[jira] [Updated] (KAFKA-502) Simplify setup / initialization in replication_basic_test.py

2012-10-01 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-502: Attachment: kafka-502-v2.patch Uploaded kafka-502-v2.patch with additional changes on top of v1: 1. Support

Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5)

2012-10-01 Thread Joel Koshy
+1 Thanks, Joel On Mon, Oct 1, 2012 at 9:05 AM, Jun Rao wrote: > +1 on RC5. > > Thanks, > > Jun > > On Fri, Sep 28, 2012 at 7:40 PM, Joe Stein wrote: > > > Hello, > > > > This is the fifth candidate for the third incubator release for Apache > > Kafka, version 0.7.2-incubating. > > > > This r

[jira] [Commented] (KAFKA-509) server should shut down on encountering invalid highwatermark file

2012-10-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13466911#comment-13466911 ] Jun Rao commented on KAFKA-509: --- Thanks for patch v1. One comment: 1. If the tmp file exists

Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 5)

2012-10-01 Thread Jun Rao
+1 on RC5. Thanks, Jun On Fri, Sep 28, 2012 at 7:40 PM, Joe Stein wrote: > Hello, > > This is the fifth candidate for the third incubator release for Apache > Kafka, version 0.7.2-incubating. > > This release fixes the following issues > > http://people.apache.org/~joestein/kafka-0.7.2-incubat

[jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server

2012-10-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-495: -- Fix Version/s: (was: 0.7.1) > Handle topic names with "/" on Kafka server >

[jira] [Updated] (KAFKA-495) Handle topic names with "/" on Kafka server

2012-10-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-495: -- Fix Version/s: 0.7.2 > Handle topic names with "/" on Kafka server > ---

[jira] Subscription: outstanding kafka patches

2012-10-01 Thread jira
Issue Subscription Filter: outstanding kafka patches (56 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-532 Multiple controllers can co-exist during soft failures https://issues.apache.org/jira/browse/KAFKA-532 KAFKA-531