[jira] [Updated] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Honghai Chen updated KAFKA-1646: Attachment: KAFKA-1646_20150616_FixFormat.patch > Improve consumer read performance for Windows > --

Review Request 35493: Improve 1646 fix by add log.preallocate

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

[jira] [Commented] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587601#comment-14587601 ] Honghai Chen commented on KAFKA-1646: - Created reviewboard https://reviews.apache.org/

Re: Review Request 33204: Patch for KAFKA-1646 fix format

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33204/ --- (Updated June 16, 2015, 7:34 a.m.) Review request for kafka. Summary (updated

[jira] [Comment Edited] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587601#comment-14587601 ] Honghai Chen edited comment on KAFKA-1646 at 6/16/15 7:38 AM: --

RE: [VOTE] KIP 20 Enable log preallocate to improve consume performance under windows and some old Linux file system

Fix done, update code review, and patch in jira. Thanks, Honghai Chen -Original Message- From: Jun Rao [mailto:j...@confluent.io] Sent: Tuesday, June 16, 2015 6:03 AM To: dev@kafka.apache.org Subject: Re: [VOTE] KIP 20 Enable log preallocate to improve consume performance under wind

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2012: --- Attachment: KAFKA-2012.patch > Broker should automatically handle corrupt index files > --

Review Request 35503: Patch for KAFKA-2012

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

[jira] [Commented] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1458#comment-1458 ] Manikumar Reddy commented on KAFKA-2012: Created reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-2012) Broker should automatically handle corrupt index files

[ https://issues.apache.org/jira/browse/KAFKA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2012: --- Assignee: Manikumar Reddy Status: Patch Available (was: Open) > Broker should automatic

Please add me to the contributor list

Hi, I am a junior undergrad from India, where I am currently working on developing streaming apps with kafka and spark. After working with it for a while, I fell I'd love to contribute to the community which will also help me learn more about the internals. I'll be glad if I could be added to the

[jira] [Updated] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Proneet Verma updated KAFKA-2270: - Attachment: fix-kafka-2270.patch Please let me know if this is a suitable patch (being my very fir

[jira] [Created] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

Olof Johansson created KAFKA-2273: - Summary: Add rebalance with a minimal number of reassignments to server-defined strategy list Key: KAFKA-2273 URL: https://issues.apache.org/jira/browse/KAFKA-2273

[jira] [Updated] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Olof Johansson updated KAFKA-2273: -- Reviewer: Guozhang Wang > Add rebalance with a minimal number of reassignments to server-defined

[jira] [Commented] (KAFKA-2078) Getting Selector [WARN] Error in I/O with host java.io.EOFException

[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588083#comment-14588083 ] Sayat Satybaldiyev commented on KAFKA-2078: --- I got the same error on Amazon inst

[jira] [Comment Edited] (KAFKA-2078) Getting Selector [WARN] Error in I/O with host java.io.EOFException

[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588083#comment-14588083 ] Sayat Satybaldiyev edited comment on KAFKA-2078 at 6/16/15 2:15 PM:

[jira] [Commented] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588109#comment-14588109 ] Jun Rao commented on KAFKA-2270: Thanks for the patch. Got a bunch of compilation errors l

Re: Please add me to the contributor list

Added. Thanks, Jun On Tue, Jun 16, 2015 at 3:07 AM, Proneet Verma wrote: > Hi, > > I am a junior undergrad from India, where I am currently working on > developing streaming apps with kafka and spark. After working with it for a > while, I fell I'd love to contribute to the community which wil

[jira] [Updated] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2270: --- Assignee: Proneet Verma > incorrect package name in unit tests > > >

[jira] [Commented] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588170#comment-14588170 ] Jun Rao commented on KAFKA-1646: [~waldenchen], thanks for the latest patch. A couple of o

[jira] [Commented] (KAFKA-2078) Getting Selector [WARN] Error in I/O with host java.io.EOFException

[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588195#comment-14588195 ] Sayat Satybaldiyev commented on KAFKA-2078: --- I made a bench one more time and er

RE: Guozhang Wang elected to Kafka PMC

Congrats Guozhang! From: Ashish Singh [asi...@cloudera.com] Sent: Monday, June 15, 2015 10:53 PM To: dev@kafka.apache.org Cc: Jun Rao Subject: Re: Guozhang Wang elected to Kafka PMC Congrats Guozhang! On Mon, Jun 15, 2015 at 10:20 PM, Sriharsha Chintalapa

Re: Review Request 34415: Patch for KAFKA-2195

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34415/#review88074 --- Thanks for the latest patch. A couple more minor comments. clients

[jira] [Updated] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Proneet Verma updated KAFKA-2270: - Attachment: fix-kafka-2270-v2.patch I compiled 'unit.kafka'. Gave no errors with this patch. Let m

Re: Review Request 34789: Patch for KAFKA-2168

> On June 15, 2015, 6:09 p.m., Jun Rao wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 1199 > > > > > > Doesn't this cause poll() to block for the backoff time? Genera

Review Request 35524: KAFKA-2092: New partitioning for better load balancing

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

Re: Guozhang Wang elected to Kafka PMC

Congrats Guozhang!! Tim On Tue, Jun 16, 2015 at 8:19 AM, Aditya Auradkar wrote: > Congrats Guozhang! > > > From: Ashish Singh [asi...@cloudera.com] > Sent: Monday, June 15, 2015 10:53 PM > To: dev@kafka.apache.org > Cc: Jun Rao > Subject: Re: Guozhang Wan

Re: Guozhang Wang elected to Kafka PMC

Congrats Guozhang! Dong On Tue, Jun 16, 2015 at 9:57 AM, Timothy Chen wrote: > Congrats Guozhang!! > > Tim > > On Tue, Jun 16, 2015 at 8:19 AM, Aditya Auradkar > wrote: > > Congrats Guozhang! > > > > > > From: Ashish Singh [asi...@cloudera.com] > > Sent

Re: Guozhang Wang elected to Kafka PMC

Thank you folks! Very glad to be onboard to PMC. Guozhang On Tue, Jun 16, 2015 at 9:59 AM, Dong Lin wrote: > Congrats Guozhang! > > Dong > > On Tue, Jun 16, 2015 at 9:57 AM, Timothy Chen wrote: > > > Congrats Guozhang!! > > > > Tim > > > > On Tue, Jun 16, 2015 at 8:19 AM, Aditya Auradkar > >

[jira] [Commented] (KAFKA-2092) New partitioning for better load balancing

[ https://issues.apache.org/jira/browse/KAFKA-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588420#comment-14588420 ] Jay Kreps commented on KAFKA-2092: -- Hmm, not sure if I follow this. My understanding of t

[jira] [Assigned] (KAFKA-1782) Junit3 Misusage

[ https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pakulov reassigned KAFKA-1782: Assignee: Alexander Pakulov (was: Jeff Holoman) > Junit3 Misusage > --

Re: Guozhang Wang elected to Kafka PMC

Congrats Guozhang! Thanks for your contributions :) On Mon, Jun 15, 2015 at 9:59 PM, Jun Rao wrote: > Hi, Everyone, > > Guozhang Wang has been active in the Kafka community since he became a > Kafka committer about 7 months ago. I am glad to announce that Guozhang is > now a member of Kafka PMC.

[jira] [Updated] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Proneet Verma updated KAFKA-2270: - Attachment: (was: fix-kafka-2270-v2.patch) > incorrect package name in unit tests > --

[jira] [Updated] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Proneet Verma updated KAFKA-2270: - Attachment: (was: fix-kafka-2270.patch) > incorrect package name in unit tests > -

[jira] [Updated] (KAFKA-1326) New consumer checklist

[ https://issues.apache.org/jira/browse/KAFKA-1326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1326: - Fix Version/s: 0.8.3 > New consumer checklist > -- > > Key: KAFKA-1326

[jira] [Resolved] (KAFKA-1000) Inbuilt consumer offset management feature for kakfa

[ https://issues.apache.org/jira/browse/KAFKA-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein resolved KAFKA-1000. -- Resolution: Fixed > Inbuilt consumer offset management feature for kakfa > -

[jira] [Updated] (KAFKA-2207) The testCannotSendToInternalTopic test method in ProducerFailureHandlingTest fails consistently with the following exception:

[ https://issues.apache.org/jira/browse/KAFKA-2207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-2207: - Fix Version/s: (was: 0.8.2.1) 0.8.3 > The testCannotSendToInternalTopic test method

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-2254: - Fix Version/s: (was: 0.8.2.1) 0.8.3 > The shell script should be optimized , even k

[jira] [Commented] (KAFKA-2159) offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored

[ https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588522#comment-14588522 ] Joel Koshy commented on KAFKA-2159: --- Yes. > offsets.topic.segment.bytes and offsets.top

[jira] [Updated] (KAFKA-2159) offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored

[ https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-2159: -- Reviewer: Joel Koshy > offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored > ---

Re: Review Request 35454: Patch for KAFKA-2159

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35454/#review88106 --- core/src/main/scala/kafka/server/KafkaConfig.scala (line 242)

[jira] [Updated] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Proneet Verma updated KAFKA-2270: - Attachment: fix-kafka-2270.patch > incorrect package name in unit tests >

[jira] [Comment Edited] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588313#comment-14588313 ] Proneet Verma edited comment on KAFKA-2270 at 6/16/15 6:41 PM: -

subscribe kafka

[jira] [Commented] (KAFKA-2195) Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest

[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588607#comment-14588607 ] Andrii Biletskyi commented on KAFKA-2195: - Updated reviewboard https://reviews.apa

Re: Review Request 34415: Patch for KAFKA-2195

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34415/ --- (Updated June 16, 2015, 7:28 p.m.) Review request for kafka. Bugs: KAFKA-2195

[jira] [Updated] (KAFKA-2195) Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest

[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-2195: Attachment: KAFKA-2195_2015-06-16_22:28:19.patch > Add versionId to AbstractRequest.getError

Re: Review Request 34415: Patch for KAFKA-2195

> On June 16, 2015, 3:52 p.m., Jun Rao wrote: > > clients/src/main/java/org/apache/kafka/common/requests/ConsumerMetadataRequest.java, > > lines 49-50 > > > > > > Perhaps it's better to include the request name in the

[jira] [Updated] (KAFKA-1328) Add new consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1328: - Fix Version/s: (was: 0.8.2.0) 0.8.3 > Add new consumer APIs > -

[jira] [Updated] (KAFKA-1328) Add new consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1328: - Affects Version/s: (was: 0.8.1) (was: 0.8.0) > Add new consumer API

[jira] [Updated] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1316: - Fix Version/s: (was: 0.8.2.0) 0.8.3 > Refactor Sender > --- > >

[jira] [Updated] (KAFKA-1331) Add ability to commit offsets to the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1331: - Assignee: Jay Kreps > Add ability to commit offsets to the new consumer >

[jira] [Updated] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) and pool(timeout) in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1330: - Affects Version/s: (was: 0.9.0) > Implement subscribe(TopicPartition...partitions) and pool(ti

[jira] [Updated] (KAFKA-1329) Add metadata fetch and refresh functionality to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1329: - Fix Version/s: 0.8.3 > Add metadata fetch and refresh functionality to the consumer >

[jira] [Updated] (KAFKA-1331) Add ability to commit offsets to the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1331: - Affects Version/s: (was: 0.9.0) > Add ability to commit offsets to the new consumer >

[jira] [Updated] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1316: - Component/s: (was: producer ) clients > Refactor Sender > --- > >

[jira] [Updated] (KAFKA-1331) Add ability to commit offsets to the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1331: - Fix Version/s: 0.8.3 > Add ability to commit offsets to the new consumer > ---

[jira] [Updated] (KAFKA-1329) Add metadata fetch and refresh functionality to the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1329: - Affects Version/s: (was: 0.9.0) > Add metadata fetch and refresh functionality to the consumer

[jira] [Updated] (KAFKA-1330) Implement subscribe(TopicPartition...partitions) and pool(timeout) in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1330: - Fix Version/s: 0.8.3 > Implement subscribe(TopicPartition...partitions) and pool(timeout) in the

[jira] [Updated] (KAFKA-1335) Add rebalancing logic to the coordinator / consumer

[ https://issues.apache.org/jira/browse/KAFKA-1335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1335: - Fix Version/s: 0.8.3 > Add rebalancing logic to the coordinator / consumer > -

[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server

[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1333: - Fix Version/s: 0.8.3 > Add consumer co-ordinator module to the server > --

[jira] [Updated] (KAFKA-1332) Add functionality to the offsetsBeforeTime() API

[ https://issues.apache.org/jira/browse/KAFKA-1332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1332: - Fix Version/s: 0.9.0 > Add functionality to the offsetsBeforeTime() API >

[jira] [Updated] (KAFKA-1334) Coordinator should detect consumer failures

[ https://issues.apache.org/jira/browse/KAFKA-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1334: - Fix Version/s: 0.8.3 > Coordinator should detect consumer failures > -

[jira] [Updated] (KAFKA-1740) Merge Offset manager into Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1740: - Priority: Critical (was: Major) > Merge Offset manager into Coordinator > ---

[jira] [Updated] (KAFKA-1740) Merge Offset manager into Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1740: - Fix Version/s: (was: 0.9.0) 0.8.3 > Merge Offset manager into Coordinator >

[jira] [Updated] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1894: - Fix Version/s: 0.9.0 > Avoid long or infinite blocking in the consumer > -

[jira] [Updated] (KAFKA-2245) Add response tests for ConsumerCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2245: - Priority: Critical (was: Major) > Add response tests for ConsumerCoordinator > --

[jira] [Updated] (KAFKA-1893) Allow regex subscriptions in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1893: - Priority: Critical (was: Major) > Allow regex subscriptions in the new consumer > ---

[jira] [Updated] (KAFKA-2245) Add response tests for ConsumerCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2245: - Fix Version/s: 0.8.3 > Add response tests for ConsumerCoordinator > --

[jira] [Updated] (KAFKA-1893) Allow regex subscriptions in the new consumer

[ https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1893: - Fix Version/s: 0.8.3 > Allow regex subscriptions in the new consumer > ---

[jira] [Updated] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2123: - Issue Type: Sub-task (was: Improvement) Parent: KAFKA-1326 > Make new consumer offset com

[jira] [Updated] (KAFKA-2123) Make new consumer offset commit API use callback + future

[ https://issues.apache.org/jira/browse/KAFKA-2123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2123: - Priority: Critical (was: Major) > Make new consumer offset commit API use callback + future > ---

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2168: - Fix Version/s: 0.8.3 > New consumer poll() can block other calls like position(), commit(), and >

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2168: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-1326 > New consumer poll() can block other

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2168: - Priority: Critical (was: Major) > New consumer poll() can block other calls like position(), comm

[jira] [Created] (KAFKA-2274) Add integration test for consumer coordinator

Guozhang Wang created KAFKA-2274: Summary: Add integration test for consumer coordinator Key: KAFKA-2274 URL: https://issues.apache.org/jira/browse/KAFKA-2274 Project: Kafka Issue Type: Sub-t

[jira] [Updated] (KAFKA-2017) Persist Coordinator State for Coordinator Failover

[ https://issues.apache.org/jira/browse/KAFKA-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2017: - Fix Version/s: 0.9.0 > Persist Coordinator State for Coordinator Failover > --

[jira] [Updated] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2273: - Fix Version/s: 0.9.0 > Add rebalance with a minimal number of reassignments to server-defined > s

[jira] [Updated] (KAFKA-1895) Investigate moving deserialization and decompression out of KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-1895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1895: - Fix Version/s: 0.9.0 > Investigate moving deserialization and decompression out of KafkaConsumer >

[jira] [Updated] (KAFKA-2239) Allow coordinator to aggresively remove group when it is no longer owning the group

[ https://issues.apache.org/jira/browse/KAFKA-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2239: - Fix Version/s: 0.9.0 > Allow coordinator to aggresively remove group when it is no longer owning t

[jira] [Updated] (KAFKA-2045) Memory Management on the consumer

[ https://issues.apache.org/jira/browse/KAFKA-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2045: - Fix Version/s: 0.9.0 > Memory Management on the consumer > - > >

[jira] [Updated] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2273: - Assignee: (was: Neha Narkhede) > Add rebalance with a minimal number of reassignments to serve

[jira] [Updated] (KAFKA-2273) Add rebalance with a minimal number of reassignments to server-defined strategy list

[ https://issues.apache.org/jira/browse/KAFKA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2273: - Labels: newbie++ (was: ) > Add rebalance with a minimal number of reassignments to server-defined

[jira] [Created] (KAFKA-2275) Add a ListTopic() API to the new consumer

Guozhang Wang created KAFKA-2275: Summary: Add a ListTopic() API to the new consumer Key: KAFKA-2275 URL: https://issues.apache.org/jira/browse/KAFKA-2275 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-2276) Initial patch for KIP-25

Geoffrey Anderson created KAFKA-2276: Summary: Initial patch for KIP-25 Key: KAFKA-2276 URL: https://issues.apache.org/jira/browse/KAFKA-2276 Project: Kafka Issue Type: Bug Re

[jira] [Updated] (KAFKA-2045) Memory Management on the consumer

[ https://issues.apache.org/jira/browse/KAFKA-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2045: - Component/s: consumer > Memory Management on the consumer > - > >

[jira] [Created] (KAFKA-2277) New producer treats requests to a disconnected broker as acks=0.

Jiangjie Qin created KAFKA-2277: --- Summary: New producer treats requests to a disconnected broker as acks=0. Key: KAFKA-2277 URL: https://issues.apache.org/jira/browse/KAFKA-2277 Project: Kafka

[jira] [Resolved] (KAFKA-2277) New producer treats requests to a disconnected broker as acks=0.

[ https://issues.apache.org/jira/browse/KAFKA-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-2277. - Resolution: Not A Problem Never mind... > New producer treats requests to a disconnected broker a

[jira] [Resolved] (KAFKA-2195) Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest

[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2195. Resolution: Fixed Thanks for the latest patch. +1 and committed to trunk. > Add versionId to AbstractReques

[GitHub] kafka pull request: Kafka 2276

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/70 Kafka 2276 Initial patch for KIP-25 Note that to install ducktape, do *not* use pip to install ducktape. Instead: ``` $ git clone g...@github.com:confluentinc/ducktape.git $

New Consumer First Release Tasks

As we have discussed in today's KIP, here is the list of tasks that is left before we can cut the first release of new consumer (and hence 0.8.3): "project = KAFKA AND resolution = Unresolved AND fixVersion = 0.8.3 AND component = consumer" in https://issues.apache.org/jira/issues/?jql= There a

[jira] [Created] (KAFKA-2278) JmxTool should support querying all objects when object-name is omitted

Dong Lin created KAFKA-2278: --- Summary: JmxTool should support querying all objects when object-name is omitted Key: KAFKA-2278 URL: https://issues.apache.org/jira/browse/KAFKA-2278 Project: Kafka

Review Request 35540: Patch for KAFKA-2278

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

[jira] [Commented] (KAFKA-2278) JmxTool should support querying all objects when object-name is omitted

[ https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588865#comment-14588865 ] Dong Lin commented on KAFKA-2278: - Created reviewboard https://reviews.apache.org/r/35540/

[jira] [Updated] (KAFKA-2278) JmxTool should support querying all objects when object-name is omitted

[ https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2278: Attachment: KAFKA-2278.patch > JmxTool should support querying all objects when object-name is omitted > ---

[jira] [Updated] (KAFKA-2278) JmxTool should support querying all objects when object-name is omitted

[ https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2278: Status: Patch Available (was: Open) > JmxTool should support querying all objects when object-name is omitt

[jira] [Resolved] (KAFKA-2270) incorrect package name in unit tests

[ https://issues.apache.org/jira/browse/KAFKA-2270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2270. Resolution: Fixed Thanks for the patch. +1. Committed to trunk after removing {} on single class imports.

[jira] [Assigned] (KAFKA-2195) Add versionId to AbstractRequest.getErrorResponse and AbstractRequest.getRequest

[ https://issues.apache.org/jira/browse/KAFKA-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-2195: -- Assignee: Andrii Biletskyi (was: Jun Rao) > Add versionId to AbstractRequest.getErrorResponse and > A

Re: Kafka KIP hangout June 16

The following are my notes for today's call. KIP-12: SSL patch is still in progress. KIP-23: Agreed to deprecate the old ConsumerOffsetChecker. new consumer: Guozhang will mark sub-tasks intended for 0.8.3 in KAFKA-1326. Thanks, Jun On Mon, Jun 15, 2015 at 3:16 PM, Jun Rao wrote: > Hi, Everyo

[jira] [Updated] (KAFKA-2272) listeners endpoint parsing fails if the hostname has capital letter

[ https://issues.apache.org/jira/browse/KAFKA-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2272: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for t

  1   2   >