Jenkins build is back to normal : kafka-trunk-jdk7 #879

See

[jira] [Commented] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046561#comment-15046561 ] Pengwei commented on KAFKA-2903: Yes we can also add comment on it. But if in the future version, someone

Build failed in Jenkins: kafka-trunk-jdk8 #208

See Changes: [wangguoz] MINOR: Remove unused DoublyLinkedList [wangguoz] HOTFIX: fix ProcessorStateManager to use correct ktable partitions -- [...truncated 1425 lines...] kafka.log.LogTest >

[jira] [Commented] (KAFKA-2953) Kafka documentation is really wide

[ https://issues.apache.org/jira/browse/KAFKA-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046695#comment-15046695 ] Jens Rantil commented on KAFKA-2953: Haha, it is a wise documentation, that's for sure :) Jokes aside,

[jira] [Comment Edited] (KAFKA-2953) Kafka documentation is really wide

[ https://issues.apache.org/jira/browse/KAFKA-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046695#comment-15046695 ] Jens Rantil edited comment on KAFKA-2953 at 12/8/15 10:23 AM: -- Haha, it is a

[GitHub] kafka pull request: KAFKA-2061: Offer a --version flag to print th...

GitHub user sasakitoa opened a pull request: https://github.com/apache/kafka/pull/639 KAFKA-2061: Offer a --version flag to print the kafka version Add version option to command line tools to print Kafka version You can merge this pull request into a Git repository by running:

[jira] [Assigned] (KAFKA-2959) Remove temporary mapping to deserialize functions in RequestChannel

[ https://issues.apache.org/jira/browse/KAFKA-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakub Nowak reassigned KAFKA-2959: -- Assignee: Jakub Nowak > Remove temporary mapping to deserialize functions in RequestChannel >

[jira] [Commented] (KAFKA-2948) Kafka producer does not cope well with topic deletions

[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046724#comment-15046724 ] Rajini Sivaram commented on KAFKA-2948: --- [~becket_qin] Thank you for your feedback. The fix that we

[jira] [Created] (KAFKA-2960) DelayedProduce may cause message lose during repeatly leader change

Xing Huang created KAFKA-2960: - Summary: DelayedProduce may cause message lose during repeatly leader change Key: KAFKA-2960 URL: https://issues.apache.org/jira/browse/KAFKA-2960 Project: Kafka

[jira] [Updated] (KAFKA-2953) Kafka documentation is really wide

[ https://issues.apache.org/jira/browse/KAFKA-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jens Rantil updated KAFKA-2953: --- Summary: Kafka documentation is really wide (was: Kafka documentation is really wise) > Kafka

[jira] [Commented] (KAFKA-2061) Offer a --version flag to print the kafka version

[ https://issues.apache.org/jira/browse/KAFKA-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046793#comment-15046793 ] ASF GitHub Bot commented on KAFKA-2061: --- GitHub user sasakitoa opened a pull request:

[jira] [Work started] (KAFKA-2959) Remove temporary mapping to deserialize functions in RequestChannel

[ https://issues.apache.org/jira/browse/KAFKA-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2959 started by Jakub Nowak. -- > Remove temporary mapping to deserialize functions in RequestChannel >

[jira] [Created] (KAFKA-2961) Add a Single Topic KafkaConsumer Helper Function

Jesse Anderson created KAFKA-2961: - Summary: Add a Single Topic KafkaConsumer Helper Function Key: KAFKA-2961 URL: https://issues.apache.org/jira/browse/KAFKA-2961 Project: Kafka Issue Type:

[jira] [Work started] (KAFKA-2064) Replace ConsumerMetadataRequest and Response with org.apache.kafka.common.requests objects

[ https://issues.apache.org/jira/browse/KAFKA-2064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2064 started by Grant Henke. -- > Replace ConsumerMetadataRequest and Response with >

[jira] [Resolved] (KAFKA-2064) Replace ConsumerMetadataRequest and Response with org.apache.kafka.common.requests objects

[ https://issues.apache.org/jira/browse/KAFKA-2064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-2064. Resolution: Fixed Looks like this was resolved by KAFKA-2687. ConsumerMetadataRequest was removed

[jira] [Assigned] (KAFKA-2064) Replace ConsumerMetadataRequest and Response with org.apache.kafka.common.requests objects

[ https://issues.apache.org/jira/browse/KAFKA-2064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2064: -- Assignee: Grant Henke > Replace ConsumerMetadataRequest and Response with >

[jira] [Assigned] (KAFKA-2507) Replace ControlledShutdown{Request,Response} with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2507: -- Assignee: Grant Henke > Replace ControlledShutdown{Request,Response} with >

[jira] [Work started] (KAFKA-2507) Replace ControlledShutdown{Request,Response} with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2507 started by Grant Henke. -- > Replace ControlledShutdown{Request,Response} with >

[jira] [Commented] (KAFKA-2961) Add a Single Topic KafkaConsumer Helper Function

[ https://issues.apache.org/jira/browse/KAFKA-2961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047141#comment-15047141 ] Jason Gustafson commented on KAFKA-2961: [~eljefe6a] I agree it's slightly annoying when you're

[jira] [Updated] (KAFKA-2960) DelayedProduce may cause message lose during repeatly leader change

[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2960: - Fix Version/s: 0.9.1.0 > DelayedProduce may cause message lose during repeatly leader change >

[jira] [Commented] (KAFKA-2507) Replace ControlledShutdown{Request,Response} with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047189#comment-15047189 ] ASF GitHub Bot commented on KAFKA-2507: --- GitHub user granthenke opened a pull request:

[jira] [Updated] (KAFKA-2507) Replace ControlledShutdown{Request,Response} with org.apache.kafka.common.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2507: --- Status: Patch Available (was: In Progress) > Replace ControlledShutdown{Request,Response} with >

[jira] [Created] (KAFKA-2962) Add Join API

Yasuhiro Matsuda created KAFKA-2962: --- Summary: Add Join API Key: KAFKA-2962 URL: https://issues.apache.org/jira/browse/KAFKA-2962 Project: Kafka Issue Type: Sub-task Components:

[jira] [Commented] (KAFKA-2961) Add a Single Topic KafkaConsumer Helper Function

[ https://issues.apache.org/jira/browse/KAFKA-2961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047213#comment-15047213 ] Jesse Anderson commented on KAFKA-2961: --- I understand your point. Maybe changing the method name

[jira] [Updated] (KAFKA-2958) Remove duplicate API key mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2958: Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was: Patch Available)

[jira] [Commented] (KAFKA-2958) Remove duplicate API key mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047153#comment-15047153 ] ASF GitHub Bot commented on KAFKA-2958: --- Github user asfgit closed the pull request at:

[jira] [Created] (KAFKA-2963) Replace server internal usage of TopicAndPartition with TopicPartition

Grant Henke created KAFKA-2963: -- Summary: Replace server internal usage of TopicAndPartition with TopicPartition Key: KAFKA-2963 URL: https://issues.apache.org/jira/browse/KAFKA-2963 Project: Kafka

[jira] [Commented] (KAFKA-2959) Remove temporary mapping to deserialize functions in RequestChannel

[ https://issues.apache.org/jira/browse/KAFKA-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047199#comment-15047199 ] Gwen Shapira commented on KAFKA-2959: - [~sinus] I don't think you can start work on this just yet. It

[jira] [Commented] (KAFKA-2960) DelayedProduce may cause message lose during repeatly leader change

[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047198#comment-15047198 ] Jiangjie Qin commented on KAFKA-2960: - [~iBuddha] In Kafka, the persistence guarantee are at different

[GitHub] kafka pull request: KAFKA-2958: Remove duplicate API key mapping f...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/637 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request: KAFKA-2507: Replace ControlledShutdown{Request...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/640 KAFKA-2507: Replace ControlledShutdown{Request,Response} with o.a.k.c… ….requests equivalent You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (KAFKA-2957) Fix typos in Kafka documentation

[ https://issues.apache.org/jira/browse/KAFKA-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-2957: --- Fix Version/s: 0.9.0.1 > Fix typos in Kafka documentation >

[jira] [Commented] (KAFKA-2948) Kafka producer does not cope well with topic deletions

[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047349#comment-15047349 ] Rajini Sivaram commented on KAFKA-2948: --- [~mgharat] [~becket_qin] The code that I am testing at the

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats Ewen! On Tue, Dec 8, 2015 at 11:39 AM, Edward Ribeiro wrote: > Congratulations, Ewen! :) > > Cheers, > Eddie > Em 08/12/2015 17:37, "Neha Narkhede" escreveu: > > > I am pleased to announce that the Apache Kafka PMC has voted to > > invite

[jira] [Commented] (KAFKA-2957) Fix typos in Kafka documentation

[ https://issues.apache.org/jira/browse/KAFKA-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047357#comment-15047357 ] ASF GitHub Bot commented on KAFKA-2957: --- GitHub user vahidhashemian opened a pull request:

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats, Ewen! On Tue, Dec 8, 2015 at 11:39 AM, Edward Ribeiro wrote: > Congratulations, Ewen! :) > > Cheers, > Eddie > Em 08/12/2015 17:37, "Neha Narkhede" escreveu: > > > I am pleased to announce that the Apache Kafka PMC has voted to > > invite

[jira] [Commented] (KAFKA-2948) Kafka producer does not cope well with topic deletions

[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047220#comment-15047220 ] Mayuresh Gharat commented on KAFKA-2948: Adding TTL would mean another user exposed config. Can we

[jira] [Commented] (KAFKA-2948) Kafka producer does not cope well with topic deletions

[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047326#comment-15047326 ] Jiangjie Qin commented on KAFKA-2948: - [~mgharat] I think TTL should not be a config but simply an

[ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

I am pleased to announce that the Apache Kafka PMC has voted to invite Ewen Cheslack-Postava as a committer and Ewen has accepted. Ewen is an active member of the community and has contributed and reviewed numerous patches to Kafka. His most significant contribution is Kafka Connect which was

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congratulations, Ewen! :) Cheers, Eddie Em 08/12/2015 17:37, "Neha Narkhede" escreveu: > I am pleased to announce that the Apache Kafka PMC has voted to > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > Ewen is an active member of the community and has

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats, Ewen! On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede wrote: > I am pleased to announce that the Apache Kafka PMC has voted to > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > Ewen is an active member of the community and has contributed and

Build failed in Jenkins: kafka-trunk-jdk8 #209

See Changes: [cshapi] KAFKA-2958: Remove duplicate API key mapping functionality -- [...truncated 3633 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[0] PASSED

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats! Ewen! On Tue, Dec 8, 2015 at 11:39 AM, Edward Ribeiro wrote: > Congratulations, Ewen! :) > > Cheers, > Eddie > Em 08/12/2015 17:37, "Neha Narkhede" escreveu: > > > I am pleased to announce that the Apache Kafka PMC has voted to > > invite

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats! Very well deserved :) Now get cranking on reviews backlog ;) On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede wrote: > I am pleased to announce that the Apache Kafka PMC has voted to > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > Ewen is an

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats! Very well deserved. On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede wrote: > I am pleased to announce that the Apache Kafka PMC has voted to > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > Ewen is an active member of the community and has

[GitHub] kafka pull request: KAFKA-2957: Fix typos in Kafka documentation

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/641 KAFKA-2957: Fix typos in Kafka documentation You can merge this pull request into a Git repository by running: $ git pull https://github.com/vahidhashemian/kafka KAFKA-2957

[jira] [Updated] (KAFKA-2957) Fix typos in Kafka documentation

[ https://issues.apache.org/jira/browse/KAFKA-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-2957: --- Status: Patch Available (was: In Progress) > Fix typos in Kafka documentation >

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Ewen, Congrats! ~ Joestein On Tue, Dec 8, 2015 at 2:51 PM, Guozhang Wang wrote: > Congrats Ewen! Welcome onboard. > > Guozhang > > On Tue, Dec 8, 2015 at 11:42 AM, Liquan Pei wrote: > > > Congrats, Ewen! > > > > On Tue, Dec 8, 2015 at 11:37 AM, Neha

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats Ewen. -Harsha On Tue, Dec 8, 2015, at 12:08 PM, Ashish Singh wrote: > Congrats Ewen! > > On Tuesday, December 8, 2015, Joe Stein wrote: > > > Ewen, > > > > Congrats! > > > > ~ Joestein > > > > On Tue, Dec 8, 2015 at 2:51 PM, Guozhang Wang >

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congratulations! Jarcec > On Dec 8, 2015, at 8:37 PM, Neha Narkhede wrote: > > I am pleased to announce that the Apache Kafka PMC has voted to > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > Ewen is an active member of the community and has

[GitHub] kafka pull request: KAFKA-2957: Fix typos in Kafka documentation

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/641 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats Ewen! Welcome onboard. Guozhang On Tue, Dec 8, 2015 at 11:42 AM, Liquan Pei wrote: > Congrats, Ewen! > > On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede wrote: > > > I am pleased to announce that the Apache Kafka PMC has voted to > > invite Ewen

[jira] [Updated] (KAFKA-2959) Remove temporary mapping to deserialize functions in RequestChannel

[ https://issues.apache.org/jira/browse/KAFKA-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakub Nowak updated KAFKA-2959: --- Assignee: (was: Jakub Nowak) > Remove temporary mapping to deserialize functions in

[jira] [Commented] (KAFKA-2957) Fix typos in Kafka documentation

[ https://issues.apache.org/jira/browse/KAFKA-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047447#comment-15047447 ] ASF GitHub Bot commented on KAFKA-2957: --- Github user asfgit closed the pull request at:

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats Ewen! On Tue, Dec 8, 2015 at 11:51 AM, Guozhang Wang wrote: > Congrats Ewen! Welcome onboard. > > Guozhang > > On Tue, Dec 8, 2015 at 11:42 AM, Liquan Pei wrote: > > > Congrats, Ewen! > > > > On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede

[jira] [Commented] (KAFKA-2959) Remove temporary mapping to deserialize functions in RequestChannel

[ https://issues.apache.org/jira/browse/KAFKA-2959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047393#comment-15047393 ] Jakub Nowak commented on KAFKA-2959: Yes, I didn't notice that earlier, so for now I will leave this

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats Ewen! On Tuesday, December 8, 2015, Joe Stein wrote: > Ewen, > > Congrats! > > ~ Joestein > > On Tue, Dec 8, 2015 at 2:51 PM, Guozhang Wang > wrote: > > > Congrats Ewen! Welcome onboard. > > > > Guozhang > > > > On Tue, Dec 8,

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Well done Ewen. Congrats. On Tue, Dec 8, 2015 at 3:18 PM, Harsha wrote: > Congrats Ewen. > -Harsha > > On Tue, Dec 8, 2015, at 12:08 PM, Ashish Singh wrote: > > Congrats Ewen! > > > > On Tuesday, December 8, 2015, Joe Stein wrote: > > > > > Ewen, > > > >

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats Ewen! -Jay On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede wrote: > I am pleased to announce that the Apache Kafka PMC has voted to > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > Ewen is an active member of the community and has contributed

[jira] [Assigned] (KAFKA-2733) Distinguish metric names inside the sensor registry

[ https://issues.apache.org/jira/browse/KAFKA-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-2733: Assignee: Guozhang Wang > Distinguish metric names inside the sensor registry >

[jira] [Work started] (KAFKA-2733) Distinguish metric names inside the sensor registry

[ https://issues.apache.org/jira/browse/KAFKA-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2733 started by Guozhang Wang. > Distinguish metric names inside the sensor registry >

[jira] [Updated] (KAFKA-2733) Distinguish metric names inside the sensor registry

[ https://issues.apache.org/jira/browse/KAFKA-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2733: - Fix Version/s: (was: 0.9.0.1) 0.9.1.0 > Distinguish metric names inside

[GitHub] kafka pull request: KAFKA-2962: stream-table table-table joins

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/644 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (KAFKA-2962) Add Simple Join API

[ https://issues.apache.org/jira/browse/KAFKA-2962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2962. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 644

[jira] [Commented] (KAFKA-2962) Add Simple Join API

[ https://issues.apache.org/jira/browse/KAFKA-2962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048211#comment-15048211 ] ASF GitHub Bot commented on KAFKA-2962: --- Github user asfgit closed the pull request at:

Build failed in Jenkins: kafka-trunk-jdk8 #214

See Changes: [wangguoz] KAFKA-2924: support offsets topic in DumpLogSegments -- [...truncated 6892 lines...] org.apache.kafka.connect.storage.OffsetStorageWriterTest > testAlreadyFlushing

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats! On Tue, Dec 8, 2015 at 2:45 PM, Jay Kreps wrote: > Congrats Ewen! > > -Jay > > On Tue, Dec 8, 2015 at 11:37 AM, Neha Narkhede wrote: > > I am pleased to announce that the Apache Kafka PMC has voted to > > invite Ewen Cheslack-Postava as a

[jira] [Commented] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047899#comment-15047899 ] Bo Wang commented on KAFKA-2965: https://github.com/apache/kafka/pull/646 [~gwenshap] please review it.

[jira] [Commented] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047898#comment-15047898 ] ASF GitHub Bot commented on KAFKA-2965: --- GitHub user boweite opened a pull request:

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats!! -James > On Dec 8, 2015, at 11:37 AM, Neha Narkhede wrote: > > I am pleased to announce that the Apache Kafka PMC has voted to > invite Ewen Cheslack-Postava as a committer and Ewen has accepted. > > Ewen is an active member of the community and has contributed and

[jira] [Created] (KAFKA-2967) Move Kafka documentation to ReStructuredText

Gwen Shapira created KAFKA-2967: --- Summary: Move Kafka documentation to ReStructuredText Key: KAFKA-2967 URL: https://issues.apache.org/jira/browse/KAFKA-2967 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhiqiang He reassigned KAFKA-2965: -- Assignee: (was: Zhiqiang He) > Two variables should be exchanged. >

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Labels: patch (was: ) Reviewer: (was: Neha Narkhede) Status: Patch Available (was: Open) >

Build failed in Jenkins: kafka-trunk-jdk8 #211

See Changes: [cshapi] KAFKA-2957: Fix typos in Kafka documentation -- [...truncated 1465 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanShutdownFile PASSED

[GitHub] kafka pull request: KAFKA-2733: Standardize metric name for Kafka ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/643 KAFKA-2733: Standardize metric name for Kafka Streams You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2733

[jira] [Commented] (KAFKA-2733) Distinguish metric names inside the sensor registry

[ https://issues.apache.org/jira/browse/KAFKA-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047676#comment-15047676 ] ASF GitHub Bot commented on KAFKA-2733: --- GitHub user guozhangwang opened a pull request:

[jira] [Updated] (KAFKA-2962) Add Simple Join API

[ https://issues.apache.org/jira/browse/KAFKA-2962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2962: Description: Stream-Table and Table-Table joins > Add Simple Join API > ---

[GitHub] kafka pull request: KAFKA-2962: stream-table table-table joins

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/644 KAFKA-2962: stream-table table-table joins @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/ymatsuda/kafka join_methods

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Description: Two variables should be exchanged in KafkaController.scala as follows： val

[GitHub] kafka pull request: KAFKA-2667: fix assertion depending on hash ma...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/642 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Attachment: Kafka-2965.patch > Two variables should be exchanged. > -- > >

[jira] [Commented] (KAFKA-2667) Copycat KafkaBasedLogTest.testSendAndReadToEnd transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047600#comment-15047600 ] Jason Gustafson commented on KAFKA-2667: I think [~becket_qin] and [~apovzner] have both seen

[jira] [Commented] (KAFKA-2960) DelayedProduce may cause message lose during repeatly leader change

[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047753#comment-15047753 ] Xing Huang commented on KAFKA-2960: --- The Partition class check log end offset and current ISR to decide

[jira] [Commented] (KAFKA-2948) Kafka producer does not cope well with topic deletions

[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047782#comment-15047782 ] ASF GitHub Bot commented on KAFKA-2948: --- GitHub user rajinisivaram opened a pull request:

subscribe

subscribe

[jira] [Commented] (KAFKA-2667) Copycat KafkaBasedLogTest.testSendAndReadToEnd transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047852#comment-15047852 ] ASF GitHub Bot commented on KAFKA-2667: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2965: Assignee: Neha Narkhede > Two variables should be exchanged. > -- >

[jira] [Commented] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047876#comment-15047876 ] Gwen Shapira commented on KAFKA-2965: - haha, yeah, I agree. [~wangbo23], Kafka project moved from

[jira] [Commented] (KAFKA-2962) Add Simple Join API

[ https://issues.apache.org/jira/browse/KAFKA-2962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047694#comment-15047694 ] ASF GitHub Bot commented on KAFKA-2962: --- GitHub user ymatsuda opened a pull request:

[GitHub] kafka pull request: KAFKA-2948: Remove unused topics from producer...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/645 KAFKA-2948: Remove unused topics from producer metadata set If no messages are sent to a topic during the last refresh interval or if UNKNOWN_TOPIC_OR_PARTITION error is received, remove the

[jira] [Created] (KAFKA-2965) Two variables should be exchanged.

Bo Wang created KAFKA-2965: -- Summary: Two variables should be exchanged. Key: KAFKA-2965 URL: https://issues.apache.org/jira/browse/KAFKA-2965 Project: Kafka Issue Type: Bug Components:

[jira] [Resolved] (KAFKA-2667) Copycat KafkaBasedLogTest.testSendAndReadToEnd transient failure

[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2667. -- Resolution: Fixed Reviewer: Ewen Cheslack-Postava (was: Guozhang Wang)

[jira] [Commented] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047855#comment-15047855 ] Bo Wang commented on KAFKA-2965: According to the code, I think the name of the two variable needs to be

[jira] [Assigned] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhiqiang He reassigned KAFKA-2965: -- Assignee: Zhiqiang He (was: Neha Narkhede) > Two variables should be exchanged. >

Build failed in Jenkins: kafka-trunk-jdk7 #881

See Changes: [cshapi] KAFKA-2957: Fix typos in Kafka documentation -- [...truncated 1439 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[19] PASSED

[jira] [Assigned] (KAFKA-2509) Replace LeaderAndIsr{Request,Response} with org.apache.kafka.common.network.requests equivalent

[ https://issues.apache.org/jira/browse/KAFKA-2509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2509: -- Assignee: Grant Henke > Replace LeaderAndIsr{Request,Response} with >

[jira] [Commented] (KAFKA-2399) Replace Stream.continually with Iterator.continually

[ https://issues.apache.org/jira/browse/KAFKA-2399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047833#comment-15047833 ] ASF GitHub Bot commented on KAFKA-2399: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2837) FAILING TEST: kafka.api.ProducerBounceTest > testBrokerFailure

[ https://issues.apache.org/jira/browse/KAFKA-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15047848#comment-15047848 ] jeanlyn commented on KAFKA-2837: [~guozhang]It seems that the buffer is full, and cause the memory

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Reviewer: Neha Narkhede Fix Version/s: 0.9.1.0 Status: Patch Available (was: Open) > Two

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhiqiang He updated KAFKA-2965: --- Labels: bug (was: patch) > Two variables should be exchanged. > -- >

  1   2   >