[jira] [Commented] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356344#comment-14356344 ] Sriharsha Chintalapani commented on KAFKA-1461: --- [~junrao] [~guozhang] pleas

[jira] [Commented] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356341#comment-14356341 ] Sriharsha Chintalapani commented on KAFKA-1461: --- Created reviewboard https:/

[jira] [Updated] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1461: -- Attachment: KAFKA-1461.patch > Replica fetcher thread does not implement any bac

Review Request 31927: Patch for KAFKA-1461

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31927/ --- Review request for kafka. Bugs: KAFKA-1461 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356326#comment-14356326 ] Ashwin Jayaprakash commented on KAFKA-1716: --- I'm beginning to wonder if the {{sh

[jira] [Comment Edited] (KAFKA-1054) Eliminate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356280#comment-14356280 ] Blake Smith edited comment on KAFKA-1054 at 3/11/15 4:51 AM: -

[jira] [Comment Edited] (KAFKA-1054) Eliminate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356280#comment-14356280 ] Blake Smith edited comment on KAFKA-1054 at 3/11/15 4:51 AM: -

[jira] [Comment Edited] (KAFKA-1054) Eliminate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356280#comment-14356280 ] Blake Smith edited comment on KAFKA-1054 at 3/11/15 4:51 AM: -

[jira] [Comment Edited] (KAFKA-1054) Eliminate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356280#comment-14356280 ] Blake Smith edited comment on KAFKA-1054 at 3/11/15 4:48 AM: -

[jira] [Updated] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashwin Jayaprakash updated KAFKA-1716: -- Attachment: kafka-shutdown-stuck.log > hang during shutdown of ZookeeperConsumerConnecto

[jira] [Commented] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356289#comment-14356289 ] Ashwin Jayaprakash commented on KAFKA-1716: --- We upgraded to Kafka 0.8.2 last wee

[jira] [Comment Edited] (KAFKA-1054) Eliminate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356280#comment-14356280 ] Blake Smith edited comment on KAFKA-1054 at 3/11/15 4:48 AM: -

[jira] [Updated] (KAFKA-1054) Eliminate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Blake Smith updated KAFKA-1054: --- Attachment: KAFKA-1054_Mar_10_2015.patch Updated to latest trunk, and squash 2 more compiler warnings.

Review Request 31925: KAFKA-1054: Fix remaining compiler warnings

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31925/ --- Review request for kafka. Bugs: KAFKA-1054 https://issues.apache.org/jira/b

Re: [DISCUSSION] KIP-15 close(timeout) for producer

The KIP page has been updated per Jay¹s comments. I¹d like to initiate the voting process if no further comments are received by tomorrow. Jiangjie (Becket) Qin On 3/8/15, 9:45 AM, "Jay Kreps" wrote: >Hey Jiangjie, > >Can you capture the full motivation and use cases for the feature? This >ment

[jira] [Commented] (KAFKA-2011) Rebalance with auto.leader.rebalance.enable=false

[ https://issues.apache.org/jira/browse/KAFKA-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14356192#comment-14356192 ] Jiangjie Qin commented on KAFKA-2011: - I took a look a the log, it seems the network w

[jira] [Commented] (KAFKA-1997) Refactor Mirror Maker

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

[jira] [Updated] (KAFKA-1997) Refactor Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1997: Attachment: KAFKA-1997_2015-03-10_18:31:34.patch > Refactor Mirror Maker > - > >

Re: Review Request 31706: Patch for KAFKA-1997

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31706/ --- (Updated March 11, 2015, 1:31 a.m.) Review request for kafka. Bugs: KAFKA-199

Re: Review Request 31706: Patch for KAFKA-1997

> On March 10, 2015, 7:10 p.m., Guozhang Wang wrote: > > core/src/main/scala/kafka/tools/MirrorMaker.scala, line 45 > > > > > > I am still a bit concerned about bounding ourselves with one producer > > per MM, becausin

Build failed in Jenkins: Kafka-trunk #422

See Changes: [wangguoz] KAFKA-1910; missed follow-up changes -- [...truncated 1726 lines...] at kafka.integration.PrimitiveApiTest.setUp(PrimitiveApiTest.scala:40) kafka.integration.Primitive

Build failed in Jenkins: KafkaPreCommit #35

See Changes: [wangguoz] KAFKA-1910; missed follow-up changes -- [...truncated 1922 lines...] at kafka.integration.PrimitiveApiTest.setUp(PrimitiveApiTest.scala:40) kafka.integration.Primiti

Build failed in Jenkins: Kafka-trunk #421

See Changes: [wangguoz] KAFKA-1910; follow-up on fixing buffer.flip on produce requests -- [...truncated 466 lines...] org.apache.kafka.common.config.AbstractConfigTest > testConfiguredInstances PAS

[jira] [Commented] (KAFKA-1910) Refactor KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355969#comment-14355969 ] Guozhang Wang commented on KAFKA-1910: -- Some changes are reverted by accident in the

Re: Create a space template for KIP

Thanks! On Tue, Mar 10, 2015 at 4:37 PM, Guozhang Wang wrote: > Got it. > > I have created the space template and modified the instructions on the KIP > wiki: > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals > > Guozhang > > On Sat, Mar 7, 2015 at 11:05 PM, Jiangj

Re: Review Request 30809: Patch for KAFKA-1888

> On March 10, 2015, 11:44 p.m., Guozhang Wang wrote: > > This is from some old review comments, I will upload rest of them soon. - Guozhang --- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30

Re: Review Request 30809: Patch for KAFKA-1888

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30809/#review73382 --- build.gradle

Re: Create a space template for KIP

Got it. I have created the space template and modified the instructions on the KIP wiki: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals Guozhang On Sat, Mar 7, 2015 at 11:05 PM, Jiangjie Qin wrote: > This is the template I am thinking about: > https://confluence

Build failed in Jenkins: KafkaPreCommit #34

See Changes: [wangguoz] KAFKA-1910; follow-up on fixing buffer.flip on produce requests -- [...truncated 466 lines...] org.apache.kafka.common.record.RecordTest > testChecksum[25] PASSED org.apache

[jira] [Commented] (KAFKA-2011) Rebalance with auto.leader.rebalance.enable=false

[ https://issues.apache.org/jira/browse/KAFKA-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355936#comment-14355936 ] K Zakee commented on KAFKA-2011: The preferred replica leader election occurred again toda

[jira] [Commented] (KAFKA-1888) Add a "rolling upgrade" system test

[ https://issues.apache.org/jira/browse/KAFKA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355921#comment-14355921 ] Abhishek Nigam commented on KAFKA-1888: --- Hi Gwen, I am not sure why the link is not

[jira] [Commented] (KAFKA-1910) Refactor KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355916#comment-14355916 ] Guozhang Wang commented on KAFKA-1910: -- Just check-in the fix, which resolves the roo

[jira] [Commented] (KAFKA-1910) Refactor KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355739#comment-14355739 ] Guozhang Wang commented on KAFKA-1910: -- Jun, I will take a look at it now. > Refacto

Re: Review Request 31850: Patch for KAFKA-1660

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review75968 --- Ship it! LGTM. Just a minor comment on one of your replies. - Guoz

[jira] [Commented] (KAFKA-1910) Refactor KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355640#comment-14355640 ] Jun Rao commented on KAFKA-1910: The most recent jenkins run has the following two unit te

Re: Review Request 31850: Patch for KAFKA-1660

> On March 9, 2015, 6:37 p.m., Guozhang Wang wrote: > > clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java, > > line 418 > > > > > > This is not related to this ticket, but I think we can just

Build failed in Jenkins: Kafka-trunk #420

See Changes: [wangguoz] KAFKA-1910; Refactor new consumer and fixed a bunch of corner cases / unit tests; reviewed by Onur Karaman and Jay Kreps -- [...truncated 1120 lines...] kafka.log.BrokerCompr

Re: Review Request 31706: Patch for KAFKA-1997

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31706/#review75921 --- core/src/main/scala/kafka/consumer/PartitionAssignor.scala

Build failed in Jenkins: KafkaPreCommit #33

See Changes: [wangguoz] KAFKA-1910; Refactor new consumer and fixed a bunch of corner cases / unit tests; reviewed by Onur Karaman and Jay Kreps -- [...truncated 1193 lines...] kafka.log.OffsetInde

[jira] [Resolved] (KAFKA-1975) testGroupConsumption occasionally hang

[ https://issues.apache.org/jira/browse/KAFKA-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1975. -- Resolution: Fixed > testGroupConsumption occasionally hang > ---

[jira] [Commented] (KAFKA-1910) Refactor KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355388#comment-14355388 ] Guozhang Wang commented on KAFKA-1910: -- Thanks for the reviews, committed to trunk. A

[jira] [Updated] (KAFKA-1948) kafka.api.consumerTests are hanging

[ https://issues.apache.org/jira/browse/KAFKA-1948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1948: - Resolution: Fixed Status: Resolved (was: Patch Available) > kafka.api.consumerTests are h

[jira] [Resolved] (KAFKA-1964) testPartitionReassignmentCallback hangs occasionally

[ https://issues.apache.org/jira/browse/KAFKA-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1964. -- Resolution: Fixed Assignee: Guozhang Wang > testPartitionReassignmentCallback hangs occas

[jira] [Commented] (KAFKA-1930) Move server over to new metrics library

[ https://issues.apache.org/jira/browse/KAFKA-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355335#comment-14355335 ] Joe Stein commented on KAFKA-1930: -- +1 to KIP, I think one thing that is going to be impo

[jira] [Commented] (KAFKA-1930) Move server over to new metrics library

[ https://issues.apache.org/jira/browse/KAFKA-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355329#comment-14355329 ] Gwen Shapira commented on KAFKA-1930: - Regardless, if we decide to switch the server t

[jira] [Commented] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355301#comment-14355301 ] Jun Rao commented on KAFKA-1461: [~guozhang], my concern is on the implementation of the D

Re: [KIP-DISCUSSION] KIP-13 Quotas

Thanks, Jay. On the interface, I agree with Aditya (and you, I believe) that we don't need to expose the public API contract at this time, but structuring the internal logic to allow for it later with low cost is a good idea. Glad you explained the thoughts on where to hold requests. While my gut

Re: adding replicas to existing topic partitions - KAFKA-1313

As Ewen suggests, you might want to take a look at KIP-6. The only thing to be careful about is not moving data for partitions other than those belonging to the topics whose replication factor is being changed by the tool. It seems logical to expose this via the kafka-topics --alter option. Thank

[jira] [Comment Edited] (KAFKA-2013) benchmark test for the purgatory

[ https://issues.apache.org/jira/browse/KAFKA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355189#comment-14355189 ] Yasuhiro Matsuda edited comment on KAFKA-2013 at 3/10/15 4:53 PM: --

[jira] [Commented] (KAFKA-2013) benchmark test for the purgatory

[ https://issues.apache.org/jira/browse/KAFKA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355189#comment-14355189 ] Yasuhiro Matsuda commented on KAFKA-2013: - This benchmark test measures the enqueu

[jira] [Comment Edited] (KAFKA-2013) benchmark test for the purgatory

[ https://issues.apache.org/jira/browse/KAFKA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355189#comment-14355189 ] Yasuhiro Matsuda edited comment on KAFKA-2013 at 3/10/15 4:53 PM: --

[jira] [Updated] (KAFKA-2013) benchmark test for the purgatory

[ https://issues.apache.org/jira/browse/KAFKA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2013: Status: Patch Available (was: Open) > benchmark test for the purgatory > --

[jira] [Commented] (KAFKA-2013) benchmark test for the purgatory

[ https://issues.apache.org/jira/browse/KAFKA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355174#comment-14355174 ] Yasuhiro Matsuda commented on KAFKA-2013: - Created reviewboard https://reviews.apa

[jira] [Updated] (KAFKA-2013) benchmark test for the purgatory

[ https://issues.apache.org/jira/browse/KAFKA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2013: Attachment: KAFKA-2013.patch > benchmark test for the purgatory > --

Review Request 31893: Patch for KAFKA-2013

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31893/ --- Review request for kafka. Bugs: KAFKA-2013 https://issues.apache.org/jira/b

[jira] [Commented] (KAFKA-1461) Replica fetcher thread does not implement any back-off behavior

[ https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355161#comment-14355161 ] Guozhang Wang commented on KAFKA-1461: -- [~junrao] Could you elaborate a bit on "diffe

[jira] [Commented] (KAFKA-527) Compression support does numerous byte copies

[ https://issues.apache.org/jira/browse/KAFKA-527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14355133#comment-14355133 ] Guozhang Wang commented on KAFKA-527: - Hi Yasuhiro, I thought for compressed writes, t

Subscript

Re: [kafka-clients] Re: [VOTE] 0.8.2.1 Candidate 2

Thanks Jun for getting this release out the door and everyone that contributed to the work in 0.8.2.1, awesome! ~ Joe Stein - - - - - - - - - - - - - - - - - http://www.stealth.ly - - - - - - - - - - - - - - - - - On Mon, Mar 9, 2015 at 2:12 PM, Jun Rao wrote: > The following are the results

Re: Can I be added as a contributor?

Thanks Joe. I added a Confluence account. On Tue, Mar 10, 2015 at 12:04 AM, Joe Stein wrote: > Grant, I added you. > > Grayson and Grant, you should both also please setup Confluence accounts > and we can grant perms to Confluence also too for your username. > > ~ Joe Stein > - - - - - - - - - -