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

2015-05-27 Thread Sadek (JIRA)
[ 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

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

2015-05-27 Thread Sadek (JIRA)
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:

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

2015-05-27 Thread Sadek (JIRA)
[ 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

2015-05-27 Thread Sadek (JIRA)
[ 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

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

2015-05-27 Thread Sadek (JIRA)
[ 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

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

2015-05-27 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561366#comment-14561366 ] Onur Karaman edited comment on KAFKA-1989 at 5/27/15 5:59 PM: --

Re: Review Request 33065: Patch for KAFKA-1928

2015-05-27 Thread Joel Koshy
--- 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.

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

2015-05-27 Thread Dave Ariens (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561459#comment-14561459 ] Dave Ariens commented on KAFKA-1686: Hi [~sriharsha], we're eagerly anticipating this

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

2015-05-27 Thread Yasuhiro Matsuda (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561470#comment-14561470 ] Yasuhiro Matsuda commented on KAFKA-1989: - Thanks. I am looking into it. Would you

Re: Review Request 33065: Patch for KAFKA-1928

2015-05-27 Thread Jun Rao
--- 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

2015-05-27 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561481#comment-14561481 ] Onur Karaman commented on KAFKA-1989: - Here's the ticket:

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

2015-05-27 Thread Onur Karaman (JIRA)
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-1686) Implement SASL/Kerberos

2015-05-27 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561509#comment-14561509 ] Sriharsha Chintalapani commented on KAFKA-1686: --- [~ariens] community is

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

2015-05-27 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561366#comment-14561366 ] Onur Karaman commented on KAFKA-1989: - Hi Yasuhiro. A NullPointerException sometimes

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

2015-05-27 Thread Theo Hultberg (JIRA)
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

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

2015-05-27 Thread Parth Brahmbhatt (JIRA)
[ 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

2015-05-27 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561105#comment-14561105 ] Parth Brahmbhatt commented on KAFKA-2225: - I would like to work on this jira if

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

2015-05-27 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561272#comment-14561272 ] Guozhang Wang commented on KAFKA-1817: -- In KAFKA-1737 we have enforced setting

Re: Review Request 33065: Patch for KAFKA-1928

2015-05-27 Thread Gwen Shapira
On May 27, 2015, 6:44 p.m., Jun Rao wrote: core/src/main/scala/kafka/network/SocketServer.scala, line 109 https://reviews.apache.org/r/33065/diff/16/?file=971264#file971264line109 Agreed with Joel's point. We should probably just create a single Metrics object in KafkaServer and

Re: Review Request 33065: Patch for KAFKA-1928

2015-05-27 Thread Jun Rao
On May 27, 2015, 6:44 p.m., Jun Rao wrote: core/src/main/scala/kafka/network/SocketServer.scala, line 109 https://reviews.apache.org/r/33065/diff/16/?file=971264#file971264line109 Agreed with Joel's point. We should probably just create a single Metrics object in KafkaServer and

Review Request 34734: Patch for KAFKA-2226

2015-05-27 Thread Yasuhiro Matsuda
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34734/ --- Review request for kafka. Bugs: KAFKA-2226

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

2015-05-27 Thread Yasuhiro Matsuda (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561724#comment-14561724 ] Yasuhiro Matsuda commented on KAFKA-2226: - Created reviewboard

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

2015-05-27 Thread Gabriel Reid (JIRA)
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

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

2015-05-27 Thread Gabriel Reid (JIRA)
[ 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

2015-05-27 Thread Gabriel Reid (JIRA)
[ 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

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

2015-05-27 Thread Dong Lin (JIRA)
[ 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 -- Key:

Re: Review Request 34170: Patch for KAFKA-2191

2015-05-27 Thread Dong Lin
--- 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:

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

2015-05-27 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562070#comment-14562070 ] Dong Lin commented on KAFKA-2171: - Created reviewboard

Re: Review Request 32869: Patch for KAFKA-2091

2015-05-27 Thread Jay Kreps
--- 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.,

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

2015-05-27 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562061#comment-14562061 ] Neha Narkhede commented on KAFKA-2168: -- There are tradeoffs to having multiple

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

2015-05-27 Thread Dong Lin (JIRA)
[ 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 33049: Patch for KAFKA-2084

2015-05-27 Thread Dong Lin
--- 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

2015-05-27 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562053#comment-14562053 ] Jun Rao commented on KAFKA-1778: [~anigam], yes, you will need to configure multiple

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

2015-05-27 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562077#comment-14562077 ] Jay Kreps commented on KAFKA-2223: -- This is a good point. There are a bunch of problems

Re: Review Request 34170: Patch for KAFKA-2191

2015-05-27 Thread Dong Lin
--- 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:

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

2015-05-27 Thread Dong Lin (JIRA)
[ 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

2015-05-27 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562074#comment-14562074 ] Dong Lin commented on KAFKA-2191: - Updated reviewboard

Re: Review Request 32869: Patch for KAFKA-2091

2015-05-27 Thread Sriharsha Chintalapani
--- 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:

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

2015-05-27 Thread Sriharsha Chintalapani (JIRA)
[ 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] [Commented] (KAFKA-2091) Expose a Partitioner interface in the new producer

2015-05-27 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561908#comment-14561908 ] Sriharsha Chintalapani commented on KAFKA-2091: --- Updated reviewboard

Re: Review Request 34608: Patch for KAFKA-2217

2015-05-27 Thread Jason Gustafson
--- 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:

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

2015-05-27 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561912#comment-14561912 ] Jason Gustafson commented on KAFKA-2217: Updated reviewboard

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

2015-05-27 Thread Jason Gustafson (JIRA)
[ 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

Re: Review Request 34608: Patch for KAFKA-2217

2015-05-27 Thread Jason Gustafson
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 https://reviews.apache.org/r/34608/diff/1/?file=969830#file969830line226 One drawback to this is that we're now constantly reallocating these

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

2015-05-27 Thread Abhishek Nigam (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14561833#comment-14561833 ] Abhishek Nigam commented on KAFKA-1778: --- Joel, What I was proposing was that all the