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

[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490238#comment-14490238 ] Clark Haskins commented on KAFKA-1669: -- The existing consumer will likely stick aroun

Please add me to the contributor list

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 o

Re: Please add me to the contributor list

Hi Vijay, Thanks for your interest in contributing to Kafka. Here is a link to some newbie JIRAs that you can start looking into. You can follow instructions to contr

Re: Review Request 33017: Fix timing issue in MetadataTest

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33017/#review79756 --- Ship it! Ship It! - Jiangjie Qin On April 9, 2015, 3:35 p.m., Ra

KIP discussion Apr 15 at 9:30 am PST

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 agend

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

[ 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.

[ 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 Jav

Re: Review Request 31850: Patch for KAFKA-1660

--- 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: KAFKA-16

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

[ https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490445#comment-14490445 ] Jiangjie Qin commented on KAFKA-1660: - Updated reviewboard https://reviews.apache.org/

Re: Review Request 31850: Patch for KAFKA-1660

> 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 > > > > > > I was trying to find a case where it wouldn't wo

Re: Review Request 31850: Patch for KAFKA-1660

--- 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

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

Vijay, Just added you to the contributor list. Thanks, Jun On Fri, Apr 10, 2015 at 3:29 PM, Vijay Bhat 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. > Is that not the

Re: Please add me to the contributor list

Thanks Jun! On Fri, Apr 10, 2015 at 3:53 PM, Jun Rao wrote: > Vijay, > > Just added you to the contributor list. > > Thanks, > > Jun > > On Fri, Apr 10, 2015 at 3:29 PM, Vijay Bhat wrote: > > > Thanks Neha. > > > > The instructions on the page mention that I need to be added to the > > contribu

Re: [DISCUSS] KIP-18 - JBOD Support

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 r

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

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490534#comment-14490534 ] Jun Rao commented on KAFKA-2068: [~guozhang], do you plan to take this on? Thanks, > Repl

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

[ 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

> 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: h

Re: Review Request 33049: Patch for KAFKA-2084

--- 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: KAFKA-20

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

[ https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490600#comment-14490600 ] Aditya A Auradkar commented on KAFKA-2084: -- Updated reviewboard https://reviews.a

Re: Review Request 33049: Patch for KAFKA-2084

--- 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: KAFKA-20

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

[ 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 (produc

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

[ https://issues.apache.org/jira/browse/KAFKA-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490624#comment-14490624 ] Jiangjie Qin commented on KAFKA-2102: - I'm with Ewen on this. We probably can take a f

Re: Review Request 31606: Patch for KAFKA-1416

--- 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: KAFKA-141

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

[ https://issues.apache.org/jira/browse/KAFKA-1416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490697#comment-14490697 ] Flutra Osmani commented on KAFKA-1416: -- Updated reviewboard https://reviews.apache.or

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

[ 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

[ 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

> On April 8, 2015, 9:56 p.m., Guozhang Wang wrote: > > core/src/test/scala/unit/kafka/utils/TestUtils.scala, line 794 > > > > > > "Default Partition: use the topic string as the key to determine the > > partition"

Re: Review Request 31606: Patch for KAFKA-1416

> On March 25, 2015, 9:51 p.m., Guozhang Wang wrote: > > core/src/test/scala/unit/kafka/integration/FetcherTest.scala, line 85 > > > > > > Import TestUtils.sendMessages It seems that this is a practice from all committ

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

[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490758#comment-14490758 ] Fangmin Lv commented on KAFKA-2055: --- Hi Guozhang, I cannot find the ConsumerBounceTest.

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

[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490762#comment-14490762 ] Sriharsha Chintalapani commented on KAFKA-2055: --- [~lvfangmin] I can see it u

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

[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490780#comment-14490780 ] Ewen Cheslack-Postava commented on KAFKA-2055: -- [~lvfangmin] You may need to

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

[ 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 org.apache.kafka.comm

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

[ https://issues.apache.org/jira/browse/KAFKA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490790#comment-14490790 ] Guozhang Wang commented on KAFKA-2068: -- Yeah I can take on this. > Replace OffsetCo

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

[ https://issues.apache.org/jira/browse/KAFKA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14490792#comment-14490792 ] Fangmin Lv commented on KAFKA-2055: --- [~ewencp] I can see the test case after pulling the