[jira] [Created] (KAFKA-978) kafka pom file has 2 entries for zookeeper (one with exclusion, one without)

2013-07-16 Thread Jason Rosenberg (JIRA)
Jason Rosenberg created KAFKA-978: - Summary: kafka pom file has 2 entries for zookeeper (one with exclusion, one without) Key: KAFKA-978 URL: https://issues.apache.org/jira/browse/KAFKA-978 Project: K

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

2013-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v3.patch Thanks for the comment. For the first comment, since I needed to mak

[jira] [Commented] (KAFKA-967) Use key range in ProducerPerformance

2013-07-16 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710589#comment-13710589 ] Joel Koshy commented on KAFKA-967: -- +1 - thanks for the patch. > Use key

[jira] [Commented] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

2013-07-16 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710571#comment-13710571 ] Joel Koshy commented on KAFKA-957: -- Thanks for incorporating 5 and 6. Couple additional co

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

2013-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v2.patch > MirrorMaker needs to preserve the key in the source cluster > -

[jira] [Updated] (KAFKA-957) MirrorMaker needs to preserve the key in the source cluster

2013-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-957: Attachment: KAFKA-957.v2.patch 5. Use java.util.Arrays.hashCode to determine which producer to send

[jira] [Commented] (KAFKA-973) Messages From Producer Not being Partitioned

2013-07-16 Thread Subbu Srinivasan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710512#comment-13710512 ] Subbu Srinivasan commented on KAFKA-973: Thanks Joel. I found the issue. I was inst

[jira] [Commented] (KAFKA-976) Order-Preserving Mirror Maker Testcase

2013-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710361#comment-13710361 ] Guozhang Wang commented on KAFKA-976: - +1, passed test with the above steps.

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

2013-07-16 Thread Scott Carey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710343#comment-13710343 ] Scott Carey commented on KAFKA-717: --- The latter plan looks good to me.

[jira] [Commented] (KAFKA-976) Order-Preserving Mirror Maker Testcase

2013-07-16 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710335#comment-13710335 ] John Fung commented on KAFKA-976: - Uploaded kafka-976-v1.patch to add testcase_5007. Please

[jira] [Updated] (KAFKA-976) Order-Preserving Mirror Maker Testcase

2013-07-16 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-976: Status: Patch Available (was: Open) > Order-Preserving Mirror Maker Testcase >

[jira] [Updated] (KAFKA-976) Order-Preserving Mirror Maker Testcase

2013-07-16 Thread John Fung (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-976: Attachment: kafka-976-v1.patch > Order-Preserving Mirror Maker Testcase > --

[jira] [Created] (KAFKA-977) Implement generation/term per leader to reconcile messages correctly

2013-07-16 Thread Sriram Subramanian (JIRA)
Sriram Subramanian created KAFKA-977: Summary: Implement generation/term per leader to reconcile messages correctly Key: KAFKA-977 URL: https://issues.apache.org/jira/browse/KAFKA-977 Project: Kaf

[jira] [Commented] (KAFKA-967) Use key range in ProducerPerformance

2013-07-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13710046#comment-13710046 ] Guozhang Wang commented on KAFKA-967: - 4. Change key type from Integer to ByteArray in

[jira] [Created] (KAFKA-976) Order-Preserving Mirror Maker Testcase

2013-07-16 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-976: --- Summary: Order-Preserving Mirror Maker Testcase Key: KAFKA-976 URL: https://issues.apache.org/jira/browse/KAFKA-976 Project: Kafka Issue Type: Test

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

2013-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13709918#comment-13709918 ] Jay Kreps commented on KAFKA-717: - Yeah I think we all want to do this, and likely it will

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

2013-07-16 Thread Scott Carey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13709915#comment-13709915 ] Scott Carey commented on KAFKA-717: --- {quote}that would be easiest for us would be post-0.

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

2013-07-16 Thread Scott Carey (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13709904#comment-13709904 ] Scott Carey commented on KAFKA-717: --- {quote}As it stands now folks are already running 0.

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

2013-07-16 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13709855#comment-13709855 ] Jay Kreps commented on KAFKA-717: - We are up for switching over at LinkedIn, and will let p

[jira] [Created] (KAFKA-975) Leader not local for partition when partition is leader

2013-07-16 Thread Dan Swanson (JIRA)
Dan Swanson created KAFKA-975: - Summary: Leader not local for partition when partition is leader Key: KAFKA-975 URL: https://issues.apache.org/jira/browse/KAFKA-975 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-975) Leader not local for partition when partition is leader (kafka.common.NotLeaderForPartitionException)

2013-07-16 Thread Dan Swanson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13709845#comment-13709845 ] Dan Swanson commented on KAFKA-975: --- I have also tried using IP instead of host names in

[jira] [Updated] (KAFKA-975) Leader not local for partition when partition is leader (kafka.common.NotLeaderForPartitionException)

2013-07-16 Thread Dan Swanson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dan Swanson updated KAFKA-975: -- Summary: Leader not local for partition when partition is leader (kafka.common.NotLeaderForPartitionExce

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

2013-07-16 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13709823#comment-13709823 ] Joe Stein commented on KAFKA-717: - Moving away from 2.8.X for the broker build would be mor