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

2015-12-08 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-2924: support offsets topic in DumpLogSegments -- [...truncated 6892 lines...] org.apache.kafka.connect.storage.OffsetStorageWriterTest > testAlreadyFlushing PASSE

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

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048211#comment-15048211 ] ASF GitHub Bot commented on KAFKA-2962: --- Github user asfgit closed the pull request

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

2015-12-08 Thread Guozhang Wang (JIRA)
[ 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 [https://gith

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

2015-12-08 Thread asfgit
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 enabl

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

2015-12-08 Thread Xing Huang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048206#comment-15048206 ] Xing Huang edited comment on KAFKA-2960 at 12/9/15 7:32 AM: We

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

2015-12-08 Thread Xing Huang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048206#comment-15048206 ] Xing Huang commented on KAFKA-2960: --- We use Kafka 0.8.2. The produce request timeout is

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

2015-12-08 Thread jeanlyn (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048162#comment-15048162 ] jeanlyn commented on KAFKA-2837: I saw some Error message from the test like {noformat} [2

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

2015-12-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048120#comment-15048120 ] Guozhang Wang commented on KAFKA-2837: -- [~jeanlyn] Hmm, I am not sure. Just curious h

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

2015-12-08 Thread Apache Jenkins Server
See

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

2015-12-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048115#comment-15048115 ] Guozhang Wang commented on KAFKA-2960: -- [~becket_qin] I think the issue here is that

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

2015-12-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2948: - Reviewer: Ewen Cheslack-Postava Fix Version/s: 0.9.0.1 Assigning to [~ewencp] to review.

[jira] [Resolved] (KAFKA-2924) Add offsets/group metadata decoder so that DumpLogSegments can be used with the offsets topic

2015-12-08 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2924. -- Resolution: Fixed Fix Version/s: 0.9.0.1 Issue resolved by pull request 622 [https://gith

[jira] [Commented] (KAFKA-2924) Add offsets/group metadata decoder so that DumpLogSegments can be used with the offsets topic

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048089#comment-15048089 ] ASF GitHub Bot commented on KAFKA-2924: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2924: support offsets topic in DumpLogSe...

2015-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/622 --- 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 enabl

[jira] [Resolved] (KAFKA-2839) Kafka connect log test failing

2015-12-08 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2839. -- Resolution: Duplicate Reviewer: Ewen Cheslack-Postava (was: Gwen Sha

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

2015-12-08 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15048065#comment-15048065 ] Grant Henke commented on KAFKA-2967: +1 > Move Kafka documentation to ReStructuredTex

[jira] [Created] (KAFKA-2970) Both UpdateMetadataRequest.java and LeaderAndIsrRequest.java have an Endpoint class

2015-12-08 Thread Grant Henke (JIRA)
Grant Henke created KAFKA-2970: -- Summary: Both UpdateMetadataRequest.java and LeaderAndIsrRequest.java have an Endpoint class Key: KAFKA-2970 URL: https://issues.apache.org/jira/browse/KAFKA-2970 Project

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

2015-12-08 Thread Apache Jenkins Server
See Changes: [junrao] KAFKA-2668; Add a metric that records the total number of metrics -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on jenkins-

[jira] [Created] (KAFKA-2969) Refactor MetadataCache to be optimal for o.a.k.c requests

2015-12-08 Thread Grant Henke (JIRA)
Grant Henke created KAFKA-2969: -- Summary: Refactor MetadataCache to be optimal for o.a.k.c requests Key: KAFKA-2969 URL: https://issues.apache.org/jira/browse/KAFKA-2969 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

2015-12-08 Thread jin xing (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047978#comment-15047978 ] jin xing commented on KAFKA-2875: - [~ijuma] hi Ismael, is there any update or feed back ab

[jira] [Resolved] (KAFKA-2668) Add a metric that records the total number of metrics

2015-12-08 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2668. Resolution: Fixed Issue resolved by pull request 328 [https://github.com/apache/kafka/pull/328] > Add a met

[GitHub] kafka pull request: KAFKA-2668; Add a metric that records the tota...

2015-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/328 --- 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 enabl

[jira] [Commented] (KAFKA-2668) Add a metric that records the total number of metrics

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047974#comment-15047974 ] ASF GitHub Bot commented on KAFKA-2668: --- Github user asfgit closed the pull request

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

2015-12-08 Thread Apache Jenkins Server
See Changes: [me] KAFKA-2667; Fix assertion depending on hash map order in -- [...truncated 1387 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[0] PASSED kafka.log.Broker

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

2015-12-08 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2508: -- Assignee: Grant Henke > Replace UpdateMetadata{Request,Response} with > org.apache.kafka.commo

[jira] [Created] (KAFKA-2968) Refactor ReplicaManager to be optimal for o.a.k.c requests

2015-12-08 Thread Grant Henke (JIRA)
Grant Henke created KAFKA-2968: -- Summary: Refactor ReplicaManager to be optimal for o.a.k.c requests Key: KAFKA-2968 URL: https://issues.apache.org/jira/browse/KAFKA-2968 Project: Kafka Issue Ty

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

2015-12-08 Thread Apache Jenkins Server
See Changes: [cshapi] MINOR: Use `EasyMock.newCapture` instead of deprecated `new Capture` [cshapi] KAFKA-2399; Replace `Stream.continually` with `Iterator.continually` [me] KAFKA-2667; Fix assertion depending on hash map order in --

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

2015-12-08 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2509: --- Status: Patch Available (was: Open) > Replace LeaderAndIsr{Request,Response} with > org.apache.kafka

[GitHub] kafka pull request: KAFKA-2509: Replace LeaderAndIsr{Request,Respo...

2015-12-08 Thread granthenke
GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/647 KAFKA-2509: Replace LeaderAndIsr{Request,Response} with o.a.k.c reque… …sts equivalent You can merge this pull request into a Git repository by running: $ git pull https://github.com/gran

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

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047950#comment-15047950 ] ASF GitHub Bot commented on KAFKA-2509: --- GitHub user granthenke opened a pull reques

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

2015-12-08 Thread Apache Jenkins Server
See

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

2015-12-08 Thread Bo Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047899#comment-15047899 ] Bo Wang commented on KAFKA-2965: https://github.com/apache/kafka/pull/646 [~gwenshap] plea

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

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

[GitHub] kafka pull request: [KAFKA-2965]Two variables should be exchanged.

2015-12-08 Thread boweite
GitHub user boweite opened a pull request: https://github.com/apache/kafka/pull/646 [KAFKA-2965]Two variables should be exchanged. You can merge this pull request into a Git repository by running: $ git pull https://github.com/boweite/kafka kafka-2965 Alternatively you can re

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

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

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

2015-12-08 Thread Gwen Shapira (JIRA)
[ 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.

2015-12-08 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047876#comment-15047876 ] Gwen Shapira commented on KAFKA-2965: - haha, yeah, I agree. [~wangbo23], Kafka proje

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

2015-12-08 Thread Bo Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047873#comment-15047873 ] Bo Wang commented on KAFKA-2965: patch submit. please review it. thanks. > Two variables

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

2015-12-08 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047874#comment-15047874 ] Ismael Juma commented on KAFKA-2967: +1 > Move Kafka documentation to ReStructuredTex

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

2015-12-08 Thread Zhiqiang He (JIRA)
[ 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. > -- >

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

2015-12-08 Thread Zhiqiang He (JIRA)
[ 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] [Created] (KAFKA-2967) Move Kafka documentation to ReStructuredText

2015-12-08 Thread Gwen Shapira (JIRA)
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] [Updated] (KAFKA-2965) Two variables should be exchanged.

2015-12-08 Thread Bo Wang (JIRA)
[ 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) > Two

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

2015-12-08 Thread Zhiqiang He (JIRA)
[ 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. >

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

2015-12-08 Thread Bo Wang (JIRA)
[ 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] [Created] (KAFKA-2966) 0.9.0 docs missing upgrade notes regarding replica lag

2015-12-08 Thread Gwen Shapira (JIRA)
Gwen Shapira created KAFKA-2966: --- Summary: 0.9.0 docs missing upgrade notes regarding replica lag Key: KAFKA-2966 URL: https://issues.apache.org/jira/browse/KAFKA-2966 Project: Kafka Issue Type

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

2015-12-08 Thread Bo Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Fix Version/s: (was: 0.9.1.0) > Two variables should be exchanged. > -- >

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

2015-12-08 Thread Ewen Cheslack-Postava (JIRA)
[ 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) Is

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

2015-12-08 Thread Bo Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047855#comment-15047855 ] Bo Wang commented on KAFKA-2965: According to the code, I think the name of the two variab

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

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047852#comment-15047852 ] ASF GitHub Bot commented on KAFKA-2667: --- Github user asfgit closed the pull request

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

2015-12-08 Thread asfgit
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 enabl

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

2015-12-08 Thread Bo Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Status: Open (was: Patch Available) > Two variables should be exchanged. > --

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

2015-12-08 Thread Bo Wang (JIRA)
[ 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] [Commented] (KAFKA-2837) FAILING TEST: kafka.api.ProducerBounceTest > testBrokerFailure

2015-12-08 Thread jeanlyn (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047848#comment-15047848 ] jeanlyn commented on KAFKA-2837: [~guozhang]It seems that the buffer is full, and cause th

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

2015-12-08 Thread Jun Rao
Congratulations, Ewen! Well deserved. Jun 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 contribute

subscribe

2015-12-08 Thread Ryan Leslie (BLOOMBERG/ 731 LEX)
subscribe

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

2015-12-08 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047838#comment-15047838 ] Ismael Juma commented on KAFKA-2965: Thanks for filing the issue. Can you please expla

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

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047833#comment-15047833 ] ASF GitHub Bot commented on KAFKA-2399: --- Github user asfgit closed the pull request

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

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

[GitHub] kafka pull request: KAFKA-2399; Replace `Stream.continually` with ...

2015-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/106 --- 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 enabl

[GitHub] kafka pull request: MINOR: Use `EasyMock.newCapture` instead of de...

2015-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/149 --- 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 enabl

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

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

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

2015-12-08 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047825#comment-15047825 ] Jiangjie Qin commented on KAFKA-2960: - Not sure I follow the issue, in that case the P

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

2015-12-08 Thread Bo Wang (JIRA)
[ 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 topicsForWhichPartitio

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

2015-12-08 Thread Bo Wang (JIRA)
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: co

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

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047782#comment-15047782 ] ASF GitHub Bot commented on KAFKA-2948: --- GitHub user rajinisivaram opened a pull req

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

2015-12-08 Thread rajinisivaram
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 to

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

2015-12-08 Thread James Cheng
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 reviewed > numerous

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

2015-12-08 Thread Xing Huang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047753#comment-15047753 ] Xing Huang commented on KAFKA-2960: --- The Partition class check log end offset and curre

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

2015-12-08 Thread Grant Henke (JIRA)
[ 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 > org.apache.kafka.common.

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

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

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

2015-12-08 Thread ymatsuda
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 Alternativ

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

2015-12-08 Thread Yasuhiro Matsuda (JIRA)
[ 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 > ---

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

2015-12-08 Thread Yasuhiro Matsuda (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2962: Summary: Add Simple Join API (was: Add Join API) > Add Simple Join API > --

[jira] [Resolved] (KAFKA-2568) New consumer hangs indefinitely when broker list is misconfigured

2015-12-08 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2568. Resolution: Fixed We ended up fixing the main problem here in KAFKA-2683. The consumer will

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

2015-12-08 Thread Guozhang Wang (JIRA)
[ 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 the

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

2015-12-08 Thread Guozhang Wang (JIRA)
[ 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] [Assigned] (KAFKA-2733) Distinguish metric names inside the sensor registry

2015-12-08 Thread Guozhang Wang (JIRA)
[ 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] [Commented] (KAFKA-2733) Distinguish metric names inside the sensor registry

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047676#comment-15047676 ] ASF GitHub Bot commented on KAFKA-2733: --- GitHub user guozhangwang opened a pull requ

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

2015-12-08 Thread guozhangwang
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 Alternativel

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

2015-12-08 Thread Sriram Subramanian
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 committer and Ewen has accepted. > > > > Ewen

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

2015-12-08 Thread Apache Jenkins Server
See Changes: [cshapi] KAFKA-2957: Fix typos in Kafka documentation -- [...truncated 1439 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[19] PASSED kafka.log.LogSegmentTes

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

2015-12-08 Thread Jay Kreps
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 and reviewed > numero

Jenkins build is back to normal : kafka_0.9.0_jdk7 #60

2015-12-08 Thread Apache Jenkins Server
See

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

2015-12-08 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047600#comment-15047600 ] Jason Gustafson commented on KAFKA-2667: I think [~becket_qin] and [~apovzner] hav

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

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047597#comment-15047597 ] ASF GitHub Bot commented on KAFKA-2667: --- GitHub user hachikuji opened a pull request

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

2015-12-08 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/642 KAFKA-2667: fix assertion depending on hash map order in KafkaBasedLogTest.testSendAndReadToEnd You can merge this pull request into a Git repository by running: $ git pull https://github.co

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

2015-12-08 Thread Apache Jenkins Server
See Changes: [cshapi] KAFKA-2957: Fix typos in Kafka documentation -- [...truncated 1465 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanShutdownFile PASSED ka

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

2015-12-08 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047586#comment-15047586 ] Ewen Cheslack-Postava commented on KAFKA-2667: -- Yes, that seems like a very l

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

2015-12-08 Thread Ismael Juma
Congratulations Ewen! Ismael On Tue, Dec 8, 2015 at 7: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 contributed and reviewed

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

2015-12-08 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047523#comment-15047523 ] Jason Gustafson commented on KAFKA-2667: [~ewencp] This test still fails 100% of t

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

2015-12-08 Thread Flavio Junqueira
Congrats, Ewen! -Flavio > On 08 Dec 2015, at 20:49, Jarek Jarcec Cecho wrote: > > 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 h

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

2015-12-08 Thread Apache Jenkins Server
See -- [...truncated 4557 lines...] org.apache.kafka.connect.json.JsonConverterTest > timeToJson PASSED org.apache.kafka.connect.json.JsonConverterTest > structToJson PASSED org.apache.kafka.connect.jso

[jira] [Updated] (KAFKA-1125) Add options to let admin tools block until finish

2015-12-08 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-1125: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-1694 > Add options to let admin tools block unt

[jira] [Created] (KAFKA-2964) Split Security Rolling Upgrade Test By Client and Broker Protocols

2015-12-08 Thread Ben Stopford (JIRA)
Ben Stopford created KAFKA-2964: --- Summary: Split Security Rolling Upgrade Test By Client and Broker Protocols Key: KAFKA-2964 URL: https://issues.apache.org/jira/browse/KAFKA-2964 Project: Kafka

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

2015-12-08 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047489#comment-15047489 ] Jason Gustafson commented on KAFKA-2961: We previously discussed changing it to se

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

2015-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047447#comment-15047447 ] ASF GitHub Bot commented on KAFKA-2957: --- Github user asfgit closed the pull request

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

2015-12-08 Thread asfgit
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 enabl

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

2015-12-08 Thread Jarek Jarcec Cecho
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 contributed and reviewed > n

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

2015-12-08 Thread Jeff Holoman
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, > > > > > > Congrats! > > > > > > ~ Joestein > >

  1   2   >