[jira] [Updated] (KAFKA-343) revisit the become leader and become follower state change operations using V3 design

2012-07-30 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-343: -- Attachment: kafka_343.diff.6 I've made changes to the waitUntilLeaderIsElectedOrChanged() to waitUntilLiveLeade

KAFKA-260

2012-07-30 Thread Jonathan Creasy
Is there a producer someplace that implements the proposed kafka-audit messages? https://issues.apache.org/jira/browse/KAFKA-260 -Jonathan

[jira] [Updated] (KAFKA-343) revisit the become leader and become follower state change operations using V3 design

2012-07-30 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-343: -- Attachment: (was: kafka_controller_v5.patch) > revisit the become leader and become follower state chang

[jira] [Updated] (KAFKA-343) revisit the become leader and become follower state change operations using V3 design

2012-07-30 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-343: -- Attachment: kafka_343.diff.5 > revisit the become leader and become follower state change operations using

[jira] [Updated] (KAFKA-181) Log errors for unrecognized config options

2012-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-181: -- Affects Version/s: 0.8 Status: Patch Available (was: Open) Attach patch v1. Added a wrapper clas

[jira] [Updated] (KAFKA-181) Log errors for unrecognized config options

2012-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-181: -- Attachment: kafka_181_v1.patch > Log errors for unrecognized config options > --

[jira] [Assigned] (KAFKA-181) Log errors for unrecognized config options

2012-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-181: - Assignee: Jun Rao > Log errors for unrecognized config options > -

Re: [DISCUSS] git as the primary data source

2012-07-30 Thread Chris Burroughs
I was originally going to follow this was a [VOTE] thread, but most of the responses are a +1 anyway. I think we can do this and it will be a significant improvement. I'll follow up with INFRA this week. We don't have to do this, or do it now. So if anyone does have concerns please do speak up.

[jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment

2012-07-30 Thread jian fan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jian fan updated KAFKA-411: --- Attachment: (was: InvalidTopic.patch) > Message Error in high cocurrent environment >

[jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment

2012-07-30 Thread jian fan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jian fan updated KAFKA-411: --- Attachment: kafka-411.patch > Message Error in high cocurrent environment > --

[jira] [Updated] (KAFKA-343) revisit the become leader and become follower state change operations using V3 design

2012-07-30 Thread Yang Ye (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Ye updated KAFKA-343: -- Attachment: kafka_controller_v5.patch 50. RequestSendThread.run(): Not sure if we need to handle AsynchronousCl

[jira] [Updated] (KAFKA-278) Issues partitioning a new topic

2012-07-30 Thread Nick Howard (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nick Howard updated KAFKA-278: -- Attachment: bootstrap_new_brokers.patch Here's a patch we applied to our fork to deal with this issue.

[jira] [Commented] (KAFKA-384) Fix intermittent test failures and remove unnecessary sleeps

2012-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13425294#comment-13425294 ] Jun Rao commented on KAFKA-384: --- +1 on v2 too. > Fix intermittent test failu

[jira] [Commented] (KAFKA-384) Fix intermittent test failures and remove unnecessary sleeps

2012-07-30 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13425274#comment-13425274 ] Jay Kreps commented on KAFKA-384: - You are my hero... > Fix intermittent t

[jira] [Commented] (KAFKA-384) Fix intermittent test failures and remove unnecessary sleeps

2012-07-30 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13425221#comment-13425221 ] Joel Koshy commented on KAFKA-384: -- +1 for v2. > Fix intermittent test fa

[jira] [Updated] (KAFKA-384) Fix intermittent test failures and remove unnecessary sleeps

2012-07-30 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-384: Attachment: kafka-384-v2.patch Thanks for the review, Jun. That is a good point. I fixed that and al

[jira] [Commented] (KAFKA-384) Fix intermittent test failures and remove unnecessary sleeps

2012-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13425180#comment-13425180 ] Jun Rao commented on KAFKA-384: --- Thanks for the patch. It looks good. Just 1 comment: 1. Asy

[jira] Subscription: outstanding kafka patches

2012-07-30 Thread jira
Issue Subscription Filter: outstanding kafka patches (45 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-425 Wrong class name in performance test scripts https://issues.apache.org/jira/browse/KAFKA-425 KAFKA-424 Remove

[jira] [Commented] (KAFKA-376) expose different data to fetch requests from the follower replicas and consumer clients

2012-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13425024#comment-13425024 ] Jun Rao commented on KAFKA-376: --- Prashanth, Thanks for the patch. Some comments: 1. In Kafk

[jira] [Commented] (KAFKA-411) Message Error in high cocurrent environment

2012-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13424952#comment-13424952 ] Jun Rao commented on KAFKA-411: --- Thanks for the patch. It may not be the right fix though sin

Re: [DISCUSS] git as the primary data source

2012-07-30 Thread Derek Chen-Becker
Just to throw in (an admittedly external) $0.02: with Git, at least, *everyone* has a full copy of the repo, +/- local changes, so even a catastrophic failure of the apache Git servers would still allow a reconstruct of the repo elsewhere (say GitHub, or a different apache server). AFAIK, this i

[jira] [Commented] (KAFKA-411) Message Error in high cocurrent environment

2012-07-30 Thread jian fan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13424769#comment-13424769 ] jian fan commented on KAFKA-411: In high cocurrent environment, the tcp server will drop so

[jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment

2012-07-30 Thread jian fan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jian fan updated KAFKA-411: --- Attachment: InvalidTopic.patch In high cocurrent environment, the tcp server will drop some package when the

[jira] [Updated] (KAFKA-411) Message Error in high cocurrent environment

2012-07-30 Thread jian fan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jian fan updated KAFKA-411: --- Fix Version/s: 0.7.2 0.8 Labels: InvalidTopic (was: ) Status: Patch A