[jira] [Updated] (KAFKA-1071) The random partition selected in DefaultEventHandler is not random across producer instances

2013-10-03 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1071: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for patch v2. +1. Committed to 0.8.

[jira] [Commented] (KAFKA-1071) The random partition selected in DefaultEventHandler is not random across producer instances

2013-10-03 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13785640#comment-13785640 ] Neha Narkhede commented on KAFKA-1071: -- Though it is unlikely that the nanosecond tim

[jira] [Commented] (KAFKA-1071) The random partition selected in DefaultEventHandler is not random across producer instances

2013-10-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13785594#comment-13785594 ] Guozhang Wang commented on KAFKA-1071: -- I tested the Random implementation a bit and

[jira] [Commented] (KAFKA-1071) The random partition selected in DefaultEventHandler is not random across producer instances

2013-10-03 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13785584#comment-13785584 ] Neha Narkhede commented on KAFKA-1071: -- It might work better if we seed the random wi

[jira] [Updated] (KAFKA-1071) The random partition selected in DefaultEventHandler is not random across producer instances

2013-10-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1071: - Attachment: KAFKA-1071.v2.patch Good point. Attached v2 for that, also tested that Random.nextInt

[jira] [Updated] (KAFKA-1072) Allow mulitple topics selected with a TopicFilter to be balanced among consumers

2013-10-03 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1072: - Fix Version/s: 0.9 > Allow mulitple topics selected with a TopicFilter to be balanced among > co

[jira] Subscription: outstanding kafka patches

2013-10-03 Thread jira
Issue Subscription Filter: outstanding kafka patches (66 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1071 The random partition selected in DefaultEventHandler is not random across producer instances https://issues.apache.org/

[jira] [Commented] (KAFKA-966) Allow high level consumer to 'nak' a message and force Kafka to close the KafkaStream without losing that message

2013-10-03 Thread Jason Rosenberg (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13785291#comment-13785291 ] Jason Rosenberg commented on KAFKA-966: --- I think a nice api would be to have an enhan

[jira] [Created] (KAFKA-1072) Allow mulitple topics selected with a TopicFilter to be balanced among consumers

2013-10-03 Thread Jason Rosenberg (JIRA)
Jason Rosenberg created KAFKA-1072: -- Summary: Allow mulitple topics selected with a TopicFilter to be balanced among consumers Key: KAFKA-1072 URL: https://issues.apache.org/jira/browse/KAFKA-1072 Pr

[jira] [Commented] (KAFKA-981) Unable to pull Kafka binaries with Ivy

2013-10-03 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13785253#comment-13785253 ] Joe Stein commented on KAFKA-981: - Next release, yes > Unable to pull Kafka binaries with

[jira] [Commented] (KAFKA-981) Unable to pull Kafka binaries with Ivy

2013-10-03 Thread Paul Doran (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13785247#comment-13785247 ] Paul Doran commented on KAFKA-981: -- Just started investigating Kafka and hit the invalid M