[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14562104#comment-14562104 ] Jay Kreps commented on KAFKA-2168: -- Yeah for processing messages we really thought about

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14562107#comment-14562107 ] Ewen Cheslack-Postava commented on KAFKA-2168: -- Agreed, it's a matter of trad

[jira] [Updated] (KAFKA-2171) System Test for Quotas

[ https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2171: Description: Initial setup and configuration: In all scenarios, we create the following entities and topic:

Re: Review Request 34170: Patch for KAFKA-2191

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34170/ --- (Updated May 28, 2015, 12:31 a.m.) Review request for kafka. Bugs: KAFKA-2191

[jira] [Commented] (KAFKA-2223) Improve distribution of data when using hash-based partitioning

[ https://issues.apache.org/jira/browse/KAFKA-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562077#comment-14562077 ] Jay Kreps commented on KAFKA-2223: -- This is a good point. There are a bunch of problems w

[jira] [Updated] (KAFKA-2191) Measured rate should not be infinite

[ https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2191: Attachment: KAFKA-2191_2015-05-27_17:28:41.patch > Measured rate should not be infinite > --

[jira] [Commented] (KAFKA-2191) Measured rate should not be infinite

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

[jira] [Commented] (KAFKA-2171) System Test for Quotas

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

[jira] [Updated] (KAFKA-2171) System Test for Quotas

[ https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2171: Status: Patch Available (was: Open) > System Test for Quotas > -- > > K

Re: Review Request 34170: Patch for KAFKA-2191

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34170/ --- (Updated May 28, 2015, 12:28 a.m.) Review request for kafka. Bugs: KAFKA-2191

[jira] [Updated] (KAFKA-2171) System Test for Quotas

[ https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2171: Attachment: KAFKA-2171.patch > System Test for Quotas > -- > > Key: KAFK

Review Request 34742: Patch for KAFKA-2171

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

Re: Review Request 32869: Patch for KAFKA-2091

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/32869/#review85476 --- Ship it! Ship It! - Jay Kreps On May 27, 2015, 10:50 p.m., Sriha

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14562061#comment-14562061 ] Neha Narkhede commented on KAFKA-2168: -- There are tradeoffs to having multiple thread

Re: Review Request 33049: Patch for KAFKA-2084

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33049/#review85465 --- core/src/main/scala/kafka/server/ClientQuotaMetrics.scala

[jira] [Commented] (KAFKA-1778) Create new re-elect controller admin function

[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562053#comment-14562053 ] Jun Rao commented on KAFKA-1778: [~anigam], yes, you will need to configure multiple (e.g.

Re: Review Request 34608: Patch for KAFKA-2217

> On May 24, 2015, 7:16 p.m., Ewen Cheslack-Postava wrote: > > clients/src/main/java/org/apache/kafka/common/network/Selector.java, line > > 226 > > > > > > One drawback to this is that we're now constantly reallocat

[jira] [Updated] (KAFKA-2217) Refactor Client Selectable Interface for Better Concurrency Options

[ https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2217: --- Attachment: KAFKA-2217_2015-05-27_15:51:14.patch > Refactor Client Selectable Interface for Be

[jira] [Commented] (KAFKA-2217) Refactor Client Selectable Interface for Better Concurrency Options

[ https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561912#comment-14561912 ] Jason Gustafson commented on KAFKA-2217: Updated reviewboard https://reviews.apach

Re: Review Request 34608: Patch for KAFKA-2217

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34608/ --- (Updated May 27, 2015, 10:52 p.m.) Review request for kafka. Bugs: KAFKA-2217

[jira] [Commented] (KAFKA-2091) Expose a Partitioner interface in the new producer

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

[jira] [Updated] (KAFKA-2091) Expose a Partitioner interface in the new producer

[ https://issues.apache.org/jira/browse/KAFKA-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2091: -- Status: Patch Available (was: In Progress) > Expose a Partitioner interface in

[jira] [Updated] (KAFKA-2091) Expose a Partitioner interface in the new producer

[ https://issues.apache.org/jira/browse/KAFKA-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-2091: -- Attachment: KAFKA-2091_2015-05-27_15:50:18.patch > Expose a Partitioner interfac

Re: Review Request 32869: Patch for KAFKA-2091

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/32869/ --- (Updated May 27, 2015, 10:50 p.m.) Review request for kafka. Bugs: KAFKA-2091

[jira] [Commented] (KAFKA-1778) Create new re-elect controller admin function

[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561833#comment-14561833 ] Abhishek Nigam commented on KAFKA-1778: --- Joel, What I was proposing was that all the

[jira] [Updated] (KAFKA-2226) NullPointerException in TestPurgatoryPerformance

[ https://issues.apache.org/jira/browse/KAFKA-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2226: Status: Patch Available (was: Open) > NullPointerException in TestPurgatoryPerformance > --

[jira] [Commented] (KAFKA-2226) NullPointerException in TestPurgatoryPerformance

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

Review Request 34734: Patch for KAFKA-2226

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

[jira] [Updated] (KAFKA-2226) NullPointerException in TestPurgatoryPerformance

[ https://issues.apache.org/jira/browse/KAFKA-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2226: Attachment: KAFKA-2226.patch > NullPointerException in TestPurgatoryPerformance > --

Re: Review Request 33065: Patch for KAFKA-1928

> On May 27, 2015, 6:44 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/network/SocketServer.scala, line 109 > > > > > > Agreed with Joel's point. We should probably just create a single > > Metrics object in Kafk

Re: Review Request 33065: Patch for KAFKA-1928

> On May 27, 2015, 6:44 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/network/SocketServer.scala, line 109 > > > > > > Agreed with Joel's point. We should probably just create a single > > Metrics object in Kafk

[jira] [Commented] (KAFKA-1686) Implement SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561509#comment-14561509 ] Sriharsha Chintalapani commented on KAFKA-1686: --- [~ariens] community is curr

[jira] [Created] (KAFKA-2226) NullPointerException in TestPurgatoryPerformance

Onur Karaman created KAFKA-2226: --- Summary: NullPointerException in TestPurgatoryPerformance Key: KAFKA-2226 URL: https://issues.apache.org/jira/browse/KAFKA-2226 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1989) New purgatory design

[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561481#comment-14561481 ] Onur Karaman commented on KAFKA-1989: - Here's the ticket: https://issues.apache.org/ji

Re: Review Request 33065: Patch for KAFKA-1928

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33065/#review85412 --- core/src/main/scala/kafka/network/SocketServer.scala

[jira] [Commented] (KAFKA-1989) New purgatory design

[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561470#comment-14561470 ] Yasuhiro Matsuda commented on KAFKA-1989: - Thanks. I am looking into it. Would you

[jira] [Commented] (KAFKA-1686) Implement SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561459#comment-14561459 ] Dave Ariens commented on KAFKA-1686: Hi [~sriharsha], we're eagerly anticipating this

Re: Review Request 33065: Patch for KAFKA-1928

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33065/#review85360 --- Ship it! Thanks for the big patch Gwen. core/src/main/scala/kafka

[jira] [Comment Edited] (KAFKA-1989) New purgatory design

[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561366#comment-14561366 ] Onur Karaman edited comment on KAFKA-1989 at 5/27/15 5:59 PM: --

[jira] [Commented] (KAFKA-1989) New purgatory design

[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561366#comment-14561366 ] Onur Karaman commented on KAFKA-1989: - Hi Yasuhiro. A NullPointerException sometimes

[jira] [Commented] (KAFKA-1817) AdminUtils.createTopic vs kafka-topics.sh --create with partitions

[ https://issues.apache.org/jira/browse/KAFKA-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561272#comment-14561272 ] Guozhang Wang commented on KAFKA-1817: -- In KAFKA-1737 we have enforced setting ZKStri

[jira] [Assigned] (KAFKA-2225) Allow fetching from ISR

[ https://issues.apache.org/jira/browse/KAFKA-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt reassigned KAFKA-2225: --- Assignee: Parth Brahmbhatt > Allow fetching from ISR > --- > >

[jira] [Commented] (KAFKA-2225) Allow fetching from ISR

[ https://issues.apache.org/jira/browse/KAFKA-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14561105#comment-14561105 ] Parth Brahmbhatt commented on KAFKA-2225: - I would like to work on this jira if th

[jira] [Created] (KAFKA-2225) Allow fetching from ISR

Theo Hultberg created KAFKA-2225: Summary: Allow fetching from ISR Key: KAFKA-2225 URL: https://issues.apache.org/jira/browse/KAFKA-2225 Project: Kafka Issue Type: Improvement Rep

[jira] [Updated] (KAFKA-2224) kafka-consumer-offset-checker when kafka offset storage is used

[ https://issues.apache.org/jira/browse/KAFKA-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-2224: - Description: Hi, It looks like kafka-consumer-offset-checker will only work when offset data is stored in zookee

[jira] [Updated] (KAFKA-2224) kafka-consumer-offset-checker when kafka offset storage is used

[ https://issues.apache.org/jira/browse/KAFKA-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-2224: - Description: Hi, It looks like kafka-consumer-offset-checker will only work when offset data is stored in zookee

[jira] [Updated] (KAFKA-2224) kafka-consumer-offset-checker when kafka offset storage is used

[ https://issues.apache.org/jira/browse/KAFKA-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-2224: - Priority: Major (was: Critical) > kafka-consumer-offset-checker when kafka offset storage is used > -

[jira] [Updated] (KAFKA-2224) kafka-consumer-offset-checker when kafka offset storage is used

[ https://issues.apache.org/jira/browse/KAFKA-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-2224: - Description: Hi, It looks like the kafka-consumer-offset-checker class will only work when offset data is stored

[jira] [Created] (KAFKA-2224) kafka-consumer-offset-checker when kafka offset storage is used

Sadek created KAFKA-2224: Summary: kafka-consumer-offset-checker when kafka offset storage is used Key: KAFKA-2224 URL: https://issues.apache.org/jira/browse/KAFKA-2224 Project: Kafka Issue Type: Im

[jira] [Updated] (KAFKA-2223) Improve distribution of data when using hash-based partitioning

[ https://issues.apache.org/jira/browse/KAFKA-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabriel Reid updated KAFKA-2223: Attachment: KAFKA-2223.patch Patch which applies hash "smearing" to hash codes before using them for

[jira] [Updated] (KAFKA-2223) Improve distribution of data when using hash-based partitioning

[ https://issues.apache.org/jira/browse/KAFKA-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabriel Reid updated KAFKA-2223: Status: Patch Available (was: Open) > Improve distribution of data when using hash-based partitioni

[jira] [Created] (KAFKA-2223) Improve distribution of data when using hash-based partitioning

Gabriel Reid created KAFKA-2223: --- Summary: Improve distribution of data when using hash-based partitioning Key: KAFKA-2223 URL: https://issues.apache.org/jira/browse/KAFKA-2223 Project: Kafka