[jira] [Commented] (KAFKA-2055) ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure

2015-04-10 Thread Fangmin Lv (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490758#comment-14490758 ] Fangmin Lv commented on KAFKA-2055: --- Hi Guozhang, I cannot find the

[jira] [Commented] (KAFKA-2055) ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure

2015-04-10 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490762#comment-14490762 ] Sriharsha Chintalapani commented on KAFKA-2055: --- [~lvfangmin] I can see it

[jira] [Commented] (KAFKA-2055) ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure

2015-04-10 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490780#comment-14490780 ] Ewen Cheslack-Postava commented on KAFKA-2055: -- [~lvfangmin] You may need to

[jira] [Commented] (KAFKA-2055) ConsumerBounceTest.testSeekAndCommitWithBrokerFailures transient failure

2015-04-10 Thread Fangmin Lv (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490792#comment-14490792 ] Fangmin Lv commented on KAFKA-2055: --- [~ewencp] I can see the test case after pulling the

[jira] [Commented] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

2015-04-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490790#comment-14490790 ] Guozhang Wang commented on KAFKA-2068: -- Yeah I can take on this. Replace

[jira] [Assigned] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

2015-04-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-2068: Assignee: Guozhang Wang Replace OffsetCommit Request/Response with

[jira] [Commented] (KAFKA-1669) Default rebalance retries and backoff should be higher

2015-04-10 Thread Clark Haskins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490238#comment-14490238 ] Clark Haskins commented on KAFKA-1669: -- The existing consumer will likely stick

Please add me to the contributor list

2015-04-10 Thread Vijay Bhat
Hi Kafka-ers, My name is Vijay Bhat and I'm very interested in contributing to the Apache Kafka project. A little about myself: My background is in CS and I've been focusing on Hadoop / Big Data technologies for designing scalable data infrastructures for the past few years. I also enjoy working

Re: Please add me to the contributor list

2015-04-10 Thread Neha Narkhede
Hi Vijay, Thanks for your interest in contributing to Kafka. Here is a link to some newbie https://issues.apache.org/jira/browse/KAFKA-2059?jql=project%20%3D%20KAFKA%20AND%20labels%20in%20(newbie%2C%20%22newbie%2B%2B%22) JIRAs that you can start looking into. You can follow instructions to

KIP discussion Apr 15 at 9:30 am PST

2015-04-10 Thread Jun Rao
We plan to have a KIP discussion on Google hangout on Apr. 15 at 9:30am PST. This is moved to a different time on Wed due to conflicts with ApacheCon next week. If you are interested in participating and have not already received a calendar invitation, please let me know. The following is the

[jira] [Updated] (KAFKA-1334) Add failure detection capability to the coordinator / consumer

2015-04-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1334: - Reviewer: Guozhang Wang Add failure detection capability to the coordinator / consumer

[jira] [Updated] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

2015-04-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1660: Attachment: KAFKA-1660_2015-04-10_15:08:54.patch Ability to call close() with a timeout on the

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-10 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated April 10, 2015, 10:09 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1660) Ability to call close() with a timeout on the Java Kafka Producer.

2015-04-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490445#comment-14490445 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-10 Thread Jiangjie Qin
On April 10, 2015, 4:36 p.m., Joel Koshy wrote: clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, line 394 https://reviews.apache.org/r/31850/diff/7/?file=921104#file921104line394 I was trying to find a case where it wouldn't work, but I

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-10 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review79761 --- Ship it! - Guozhang Wang On April 10, 2015, 10:09 p.m., Jiangjie

Re: Please add me to the contributor list

2015-04-10 Thread Vijay Bhat
Thanks Neha. The instructions on the page mention that I need to be added to the contributor list before I can assign a JIRA to myself and begin work on it. Is that not the procedure? Right now I don't see an Assign to me link on the JIRAs (which I see in other Hadoop projects). -Vijay On Fri,

Re: Please add me to the contributor list

2015-04-10 Thread Jun Rao
Vijay, Just added you to the contributor list. Thanks, Jun On Fri, Apr 10, 2015 at 3:29 PM, Vijay Bhat vijaysb...@gmail.com wrote: Thanks Neha. The instructions on the page mention that I need to be added to the contributor list before I can assign a JIRA to myself and begin work on it.

Re: Please add me to the contributor list

2015-04-10 Thread Vijay Bhat
Thanks Jun! On Fri, Apr 10, 2015 at 3:53 PM, Jun Rao j...@confluent.io wrote: Vijay, Just added you to the contributor list. Thanks, Jun On Fri, Apr 10, 2015 at 3:29 PM, Vijay Bhat vijaysb...@gmail.com wrote: Thanks Neha. The instructions on the page mention that I need to be

Re: [DISCUSS] KIP-18 - JBOD Support

2015-04-10 Thread Jun Rao
Andrii, 1. I was wondering what if the controller fails over after step 4). Since the ZK node is gone, how does the controller know those failed replicas due to disk failures? Otherwise, the controller will assume those replicas are alive again. 2. Just to clarify. In the proposal, those failed

[jira] [Commented] (KAFKA-2068) Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent

2015-04-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490534#comment-14490534 ] Jun Rao commented on KAFKA-2068: [~guozhang], do you plan to take this on? Thanks,

[jira] [Updated] (KAFKA-1927) Replace requests in kafka.api with requests in org.apache.kafka.common.requests

2015-04-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1927: --- Status: In Progress (was: Patch Available) Actual patch is now distributed in sub jiras. Replace requests

Re: Review Request 33017: Fix timing issue in MetadataTest

2015-04-10 Thread Jiangjie Qin
On April 10, 2015, 9:52 p.m., Jiangjie Qin wrote: Ship It! BTW, I think KafkaProducer has the same issue there. Could you update the code there as well? - Jiangjie --- This is an automatically generated e-mail. To reply, visit:

Re: Review Request 33049: Patch for KAFKA-2084

2015-04-10 Thread Aditya Auradkar
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33049/ --- (Updated April 11, 2015, 12:24 a.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-2084) byte rate metrics per client ID (producer and consumer)

2015-04-10 Thread Aditya A Auradkar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490600#comment-14490600 ] Aditya A Auradkar commented on KAFKA-2084: -- Updated reviewboard

Re: Review Request 33049: Patch for KAFKA-2084

2015-04-10 Thread Aditya Auradkar
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33049/ --- (Updated April 11, 2015, 12:25 a.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-2084) byte rate metrics per client ID (producer and consumer)

2015-04-10 Thread Aditya A Auradkar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aditya A Auradkar updated KAFKA-2084: - Attachment: KAFKA-2084_2015-04-10_17:24:34.patch byte rate metrics per client ID

[jira] [Commented] (KAFKA-2102) Remove unnecessary synchronization when managing metadata

2015-04-10 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490624#comment-14490624 ] Jiangjie Qin commented on KAFKA-2102: - I'm with Ewen on this. We probably can take a

Re: Review Request 31606: Patch for KAFKA-1416

2015-04-10 Thread Flutra Osmani
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31606/ --- (Updated April 11, 2015, 1:36 a.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1416) Unify sendMessages/getMessages in unit tests

2015-04-10 Thread Flutra Osmani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14490697#comment-14490697 ] Flutra Osmani commented on KAFKA-1416: -- Updated reviewboard

[jira] [Updated] (KAFKA-1416) Unify sendMessages/getMessages in unit tests

2015-04-10 Thread Flutra Osmani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flutra Osmani updated KAFKA-1416: - Status: Patch Available (was: In Progress) Unify sendMessages/getMessages in unit tests

[jira] [Updated] (KAFKA-1416) Unify sendMessages/getMessages in unit tests

2015-04-10 Thread Flutra Osmani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flutra Osmani updated KAFKA-1416: - Attachment: KAFKA-1416_2015-04-10_18:36:10.patch Unify sendMessages/getMessages in unit tests

Re: Review Request 31606: Patch for KAFKA-1416

2015-04-10 Thread Flutra Osmani
On April 8, 2015, 9:56 p.m., Guozhang Wang wrote: core/src/test/scala/unit/kafka/utils/TestUtils.scala, line 794 https://reviews.apache.org/r/31606/diff/2-3/?file=881937#file881937line794 Default Partition: use the topic string as the key to determine the partition Yes, this is

Re: Review Request 31606: Patch for KAFKA-1416

2015-04-10 Thread Flutra Osmani
On March 25, 2015, 9:51 p.m., Guozhang Wang wrote: core/src/test/scala/unit/kafka/integration/FetcherTest.scala, line 85 https://reviews.apache.org/r/31606/diff/2/?file=881933#file881933line85 Import TestUtils.sendMessages It seems that this is a practice from all committers